I have two Java applications: AppOne and AppTwo. In AppOne, I used a JMS sender to publish a Topic. In both AppOne and AppTwo, I used a JMS MessageListener to subscribe to
the message published by AppOne. I used ActiveMQ as my JMS broker and Spring JMS. However, I can only see
the echoed message received by AppOne message listener. But I can't see
the echoed message received by AppTwo listener. AppOne message listener is in
the same application/project as
the message publisher. But AppTwo message listener is in a different application/project.
The AppOne listener class is:
public class CustomerStatusListener implements MessageListener {
public void onMessage(Message message) {
if (message instanceof TextMessage) {
try {
System.out.println("Subscriber 1 got you!
The message is: " + ((TextMessage) message).getText());
} catch (JMSException ex) {
throw new RuntimeException(ex);
}
} else {
throw new IllegalArgumentException("Message must be of type TextMessage");
}
}
}
It is invoked by a test calss JmsTest in AppOne:
public class JmsTest {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("message-bean.xml");
CustomerStatusSender messageSender = (CustomerStatusSender) context.getBean("customerMessageSender");
messageSender.simpleSend();
context.close();
}
}
The AppTwo listener class is:
public class CustomerStatusMessageListener implements MessageListener {
public void onMessage(Message message) {
if (message instanceof TextMessage) {
try {
System.out.println("Subscriber 2 got you!
The message is: "
+ ((TextMessage) message).getText());
} catch (JMSException ex) {
throw new RuntimeException(ex);
}
} else {
throw new IllegalArgumentException(
"Message must be of type TextMessage");
}
}
}
The bean definition file for AppTwo where
the Subscriber 2 lives in is:
<bean id="connectionFactoryBean" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<!-- this is
the Message Driven POJO (MDP) -->
<bean id="customerStatusListener" class="com.mydomain.jms.CustomerStatusMessageListener" />
<!-- and this is
the message listener container -->
<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactoryBean" />
<property name="destination" ref="topicBean" />
<property name="messageListener" ref="customerStatusListener" />
</bean>
The bean id topicBean is
the bean that is associated with
the publisher.
If both listener received
the message sent from AppOne, I would have seen two echoed messages:
Subscriber 1 got you!
The message is: hello world
Subscriber 2 got you!
The message is: hello world
But right now I only see
the first line which means only
the listener in AppOne got
the message. So how to let
the listener in AppTwo get
the message?
The first listener is in
the same application as
the sender, so it is easy to understand that it can get
the message. But how about
the second listener which is in a different application? What is
the correct way to subscribe to a JMS Topic published in another application?
