Skip to content

Instantly share code, notes, and snippets.

@danielkec

danielkec/ActiveMQSeJNDIExample.java

Last active December 7, 2020 12:49
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save danielkec/5c288d3f08fe622039e8d142dc475cd0 to your computer and use it in GitHub Desktop.
Save danielkec/5c288d3f08fe622039e8d142dc475cd0 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ActiveMQSeJNDIExample.java
// 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