Hi all,
I have a small problem with distributed queues. I am using JBoss AS 5.0.1.GA.
What I want is to send the message to all the topics with the same JNDI Names on the cluster nodes. I have set the clustered property of the topics to true but doesn't help. Is there a way to do it?
My code:
on one node I create the InitialContext
InitialContext context = new InitialContext(); Object tmp = context.lookup(JndiName); ConnectionFactory cf = (ConnectionFactory) tmp; Connection connection = cf.createConnection(); Session session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE); Destination destination = (Destination) context.lookup(TOPIC);
<mbean code="org.jboss.jms.server.destination.TopicService" name="jboss.messaging.destination:service=Topic,name=JMS_TOPIC" xmbean-dd="xmdesc/Topic-xmbean.xml"> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends> <depends>jboss.messaging:service=PostOffice</depends> <attribute name="JNDIName">tst/JMS_TOPIC</attribute> <attribute name="Clustered">true</attribute> </mbean>