I am having the same issue since integrating the MessageBroker with Spring. Do you have an example that does the same thing as MessageBroker.getMessageBroker?