class MessageBusServer {

    void startServer(String routerHost, int routerPort) throws Exception {
        LoggingService.logDebug(MODULE_NAME, "Starting server");
        JmsConnectionFactory connectionFactory = new JmsConnectionFactory(String.format("amqp://%s:%d", routerHost, routerPort));
        connection = connectionFactory.createConnection();
        LoggingService.logDebug(MODULE_NAME, "Finished starting server");
    }

}