Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
// Setup connector
JmsConnector seConn = JmsConnector.create();
// Prepare channels
Channel<String> toJms = Channel.<String>builder()
.name("to-jms")
.subscriberConfig(JmsConnector.configBuilder()
.queue("example_queue_1")
.jndiInitialFactory(ActiveMQInitialContextFactory.class)
.jndiProviderUrl("tcp://192.168.0.123:61616")
.build())
.build();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment