class MessageBusServer {

    void initialize() throws Exception {
        LoggingService.logDebug(MODULE_NAME, "Starting initialization");
        synchronized (messageBusSessionLock) {
            session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
            connection.start();
        }
        LoggingService.logDebug(MODULE_NAME, "Finished initialization");
    }

}