public SourceSession createSourceSession(SourceSessionParams params) {
        if (destroyed.get()) {
            throw new IllegalStateException("Object is destroyed.");
        }
        return new SourceSession(this, params);
    }
<p>Creates a source session on top of this message bus.</p>

@param params The parameters to control the session.
@return The created session.
messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java