Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
public void startBroker() throws Exception {
context = new DefaultCamelContext();
context.addComponent("jms-broker", activeMQComponent("vm://localhost?broker.persistent=false"));
buildProducerRoute(context);
buildConsumerRoute(context);
context.start();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment