Hi,
We are using hornetq.2.2.5 + jboss 5.1.0.GA in a clustered environment. The configuration is pretty basic nothing special, just several topics and queues in hornetq-jms.xml.
There is no problem with queues - they work really fine. But topics does not work: the problem is that sending to the topic does not raise any exception but no messages really arrive to the destination. At least jmx-console shows 0 in messages counter and the consumer cannot consume messages from the topic - again no exceptions raised, just like there are no messages in the topic at all.
Here is how we send messages to the topic:
Hashtable<String, String> jndiParameters = new Hashtable<String, String>(); jndiParameters.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory"); jndiParameters.put("java.naming.factory.url.pkgs=", "org.jboss.naming:org.jnp.interfaces"); jndiParameters.put(javax.naming.Context.PROVIDER_URL,"jnp://192.168.168.194:1199"); initialContext = new InitialContext(jndiParameters); ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); connection = cf.createConnection(); Topic topic = (Topic) initialContext.lookup("/topic/TestsOnlyTopic"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); TextMessage msg = session.createTextMessage("TEXT MESSAGE"); MessageProducer producer = session.createProducer(topic); producer.send(msg); session.close(); producer.close();
Could you please advise what to do to make it work?