How to connect an MDB to a remote queue on 7.1 Beta1?
lars-ho Nov 28, 2011 8:28 AMI have an MDB that should listen to a remote HorentQ queue. I have tryed the following configuration in standalone-full.xml:
{code:xml}
<subsystem xmlns="urn:jboss:domain:messaging:1.1">
<hornetq-server>
...
<connectors>
<netty-connector name="netty" socket-binding="messaging-client"/>
<netty-connector name="netty-throughput" socket-binding="messaging-throughput-client">
<param key="batch-delay" value="50"/>
</netty-connector>
<in-vm-connector name="in-vm" server-id="0"/>
</connectors>
...
<socket-binding-group name="standard-sockets" default-interface="public">
...
<outbound-socket-binding name="messaging-client">
<remote-destination host="1.2.3.4" port="5445"/>
</outbound-socket-binding>
<outbound-socket-binding name="messaging-throughput-client">
<remote-destination host="1.2.3.4" port="5455"/>
</outbound-socket-binding>
</socket-binding-group>
{code}
When I deploy my MDB, it logs the following:
13:46:50,629 INFO [org.hornetq.ra.inflow.HornetQActivation] (default-short-running-threads-threads - 2) Attempting to reconnect org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@1e7258e destination=queue/textQueue destinationType=javax.jms.Queue ack=Auto-acknowledge durable=false clientID=null user=null maxSession=15)
13:46:50,632 INFO [org.hornetq.ra.inflow.HornetQActivation] (default-short-running-threads-threads - 2) awaiting topic/queue creation queue/textQueue
I am certain that the remote queue is actually there, because this same MDB was working in AS 7.0, but then with a @ResourceAdapter("jms-ra.rar") annotation where jms-ra.rar had the remote queue configured in ra.xml:
{code:xml}
<config-property> | ||
<description>The transport type</description> | ||
<config-property-name>ConnectorClassName</config-property-name> | ||
<config-property-type>java.lang.String</config-property-type> | ||
<config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value> | ||
</config-property> | ||
<config-property> | ||
<description>The transport configuration. These values must be in the form of key=val;key=val;</description> | ||
<config-property-name>ConnectionParameters</config-property-name> | ||
<config-property-type>java.lang.String</config-property-type> |
<config-property-value>host=1.2.3.4;port=5445</config-property-value> | ||
</config-property> |
{code}
What am I missing?