Subscribing to topic on different AS version
I have a simple publisher/subscriber that I'm trying to get working across different servers. I need a subscriber MDB to run on a JBoss EAP 6.1 server being driven by a topic on a JBoss 7.1.1 server. My hornetq versions appear to be 2.3.1.Final-redhat-1 on EAP and 2.2.13.Final on 7.1.1. My simple example works as I'd expect it when I'm using either both EAP servers or both 7.1.1 servers, but when I try my desired configuration (EAP 6.1 - 7.1.1) I get the following:
09:12:16,866 INFO [org.hornetq.ra] (default-threads - 1) HQ151001: Attempting to reconnect org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@18
dad2f destination=topic3 destinationType=javax.jms.Topic ack=Auto-acknowledge durable=false clientID=null user=testuser password=**** maxSession=15)
And I never end up connecting or getting any messages in the MDB.
My code follows:
@Singleton
@Startup
public class NotifierSingleton {
@Resource
private TimerService ts;
@Resource(lookup = "java:/topic/mytopic3")
private Destination d;
@Resource(lookup = "java:/ConnectionFactory")
private ConnectionFactory cf;
private static final Logger l = Logger.getLogger(NotifierSingleton.class);
@PostConstruct
public void pc() {
ts.createIntervalTimer(5000, 5000, new TimerConfig(null, false));
}
@Timeout
public void timeout() {
Connection conn = null;
Session sess = null;
MessageProducer mp = null;
try {
conn = cf.createConnection();
sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
mp = sess.createProducer(d);
l.info("Sending message");
mp.send(sess.createTextMessage("notification message"));
}
catch (Exception e) {
l.error("", e);
}
finally {
if (mp != null) {
try {
mp.close();
}
catch (Exception e) {
l.error("", e);
}
}
if (sess != null) {
try {
sess.close();
}
catch (Exception e) {
l.error("", e);
}
}
if (conn != null) {
try {
conn.close();
}
catch (Exception e) {
l.error("", e);
}
}
}
}
}
public class MyTopicSubscriber implements MessageListener {
private static final Logger l = Logger.getLogger(MyTopicSubscriber.class);
/**
* @see javax.jms.MessageListener#onMessage(javax.jms.Message)
*/
@Override
public void onMessage(Message arg0) {
System.out.println("here");
l.info("Received message - " + arg0);
if (arg0 instanceof TextMessage) {
try {
l.info("Message contents - " + ((TextMessage) arg0).getText());
}
catch (JMSException e) {
l.error("Failed to get text from message.", e);
}
}
}
}
}
<?xml version="1.0" encoding="UTF-8"?> <ejb-jar xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:ejb="http://java.sun.com/xml/ns/javaee/ejb-jar_3_0.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/ejb-jar_3_1.xsd" version="3.1"> <display-name>TopicSubscription</display-name> <enterprise-beans> <message-driven> <ejb-name>TopicSubscriber</ejb-name> <ejb-class>com.marcdejose.test.TopicSubscription.MyTopicSubscriber</ejb-class> <activation-config> <activation-config-property> <activation-config-property-name>destinationType</activation-config-property-name> <activation-config-property-value>javax.jms.Topic</activation-config-property-value> </activation-config-property> <activation-config-property> <activation-config-property-name>destination</activation-config-property-name> <activation-config-property-value>topic3</activation-config-property-value> </activation-config-property> <activation-config-property> <activation-config-property-name>connectorClassName</activation-config-property-name> <activation-config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</activation-config-property-value> </activation-config-property> <activation-config-property> <activation-config-property-name>connectionParameters</activation-config-property-name> <activation-config-property-value>host=localhost;port=5545</activation-config-property-value> </activation-config-property> <activation-config-property> <activation-config-property-name>user</activation-config-property-name> <activation-config-property-value>testuser</activation-config-property-value> </activation-config-property> <activation-config-property> <activation-config-property-name>password</activation-config-property-name> <activation-config-property-value>testpass</activation-config-property-value> </activation-config-property> </activation-config> </message-driven> </enterprise-beans> </ejb-jar>
I thought maybe I should try driving my MDB from the resource adapter from the same version of HornetQ as I have running on 7.1.1, but believe I ran into this bug:
https://issues.jboss.org/browse/HORNETQ-1030?page=com.atlassian.jirafisheyeplugin:fisheye-issuepanel
Do I have something misconfigured? Should I expect my MDB on EAP to work with the libraries in place or is it correct that I should be using the HornetQ RA with the same version? Should I have posted this in the AS forum?
