Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration("org.hornetq.core.remoting.impl.invm.InVMConnectorFactory"));
- ClientSessionFactory sf = locator.createSessionFactory();
- session = sf.createSession(false, true, true);
- final SimpleString QUEUE = new SimpleString(queueName);
- session.createQueue(QUEUE, QUEUE, null, false);
Add Comment
Please, Sign In to add comment