All
When I deploy qpid-ra-0.17.rar to JBoss7 standalone, it starts up fine. I
can see that it is registered in the jboss management console under
resource adapters.
However, when I execute "connectionFactory.createConnection", I get the
error below:
12/06/06 11:38:20 INFO jndi.PropertiesFileInitialContextFactory: Loading
Properties from:/jboss-as-7.1.1.Final/qpid-jndi.properties
12/06/06 11:38:20 INFO jndi.PropertiesFileInitialContextFactory: Loaded
Context Properties:{topic.ibmStocks=stocks.nyse.ibm,
java.naming.provider.url=/jboss-as-7.1.1.Final/qpid-jndi.properties,
java.naming.factory.initial=org.apache.qpid.jndi.PropertiesFileInitialContextFactory,
connectionfactory.QpidJMSXA=amqp://guest:guest@/test?brokerlist='tcp://localhost:5672',
destination.direct=direct://amq.direct//directQueue,
connectionfactory.local=amqp://guest:guest@/test?brokerlist='tcp://localhost:5672',
queue.MyQueue=jms/iharvest.dragonActivityQpid}
12/06/06 11:38:22 INFO client.AMQConnection:
Connection:amqp://guest:********@JDaughtery-PC1338997100780/test?brokerlist='tcp://localhost:5672'
12/06/06 11:38:22 INFO protocol.AMQProtocolSession: Using ProtocolVersion
for Session:0-10
12/06/06 11:38:22 INFO handler.ClientMethodDispatcherImpl: New Method
Dispatcher:AMQProtocolSession[null]
12/06/06 11:38:22 INFO client.AMQConnection: Connecting with
ProtocolHandler Version:0-10
12/06/06 11:38:23 INFO client.AMQConnection: Unable to connect to broker at
tcp://localhost:5672
org.apache.qpid.transport.TransportException: Error connecting to broker
at
org.apache.qpid.transport.network.io.IoNetworkTransport.connect(IoNetworkTransport.java:70)
at org.apache.qpid.transport.Connection.connect(Connection.java:252)
at
org.apache.qpid.client.AMQConnectionDelegate_0_10.makeBrokerConnection(AMQConnectionDelegate_0_10.java:193)
at
org.apache.qpid.client.AMQConnection.makeBrokerConnection(AMQConnection.java:569)
at org.apache.qpid.client.AMQConnection.<init>(AMQConnection.java:355)
at
org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:98)
at sandbox.SandBox.main(SandBox.java:38)
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351)
at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213)
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
at java.net.Socket.connect(Socket.java:529)
at java.net.Socket.connect(Socket.java:478)
at
org.apache.qpid.transport.network.io.IoNetworkTransport.connect(IoNetworkTransport.java:66)
... 6 more
javax.jms.JMSException: Error creating connection: Connection refused:
connect
at
org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:102)
at sandbox.SandBox.main(SandBox.java:38)
Caused by: org.apache.qpid.AMQConnectionFailureException: Connection
refused: connect
at org.apache.qpid.client.AMQConnection.<init>(AMQConnection.java:432)
at
org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:98)
... 1 more
Caused by: org.apache.qpid.transport.TransportException: Error connecting
to broker
at
org.apache.qpid.transport.network.io.IoNetworkTransport.connect(IoNetworkTransport.java:70)
at org.apache.qpid.transport.Connection.connect(Connection.java:252)
at
org.apache.qpid.client.AMQConnectionDelegate_0_10.makeBrokerConnection(AMQConnectionDelegate_0_10.java:193)
at
org.apache.qpid.client.AMQConnection.makeBrokerConnection(AMQConnection.java:569)
at org.apache.qpid.client.AMQConnection.<init>(AMQConnection.java:355)
... 2 more
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351)
at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213)
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
at java.net.Socket.connect(Socket.java:529)
at java.net.Socket.connect(Socket.java:478)
at
org.apache.qpid.transport.network.io.IoNetworkTransport.connect(IoNetworkTransport.java:66)
... 6 more
Code that results in the exception:
String _url = "amqp://guest:guest@/test?brokerlist='tcp://localhost:5672'";
Properties properties = new Properties();
properties.put(Context.INITIAL_CONTEXT_FACTORY,
INITIAL_CONTEXT_FACTORY);
properties.put("connectionfactory." + "QpidJMSXA", _url);
properties.put("java.naming.provider.url",
"/jboss-as-7.1.1.Final/qpid-jndi.properties");
try {
InitialContext ctx = new InitialContext(properties);
ConnectionFactory jndi = (ConnectionFactory)
ctx.lookup("QpidJMSXA");
Connection _conn = ((ConnectionFactory)
jndi).createConnection();
_conn.start();
Session _session = _conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
The standalone-full.xml snippet with the resource adapter elements:
<subsystem xmlns="urn:jboss:domain:resource-adapters:1.0">
<resource-adapters>
<resource-adapter>
<archive>
qpid-ra-0.17.rar
</archive>
<transaction-support>XATransaction</transaction-support>
<config-property name="connectionURL">
@broker.url@
</config-property>
<config-property name="TransactionManagerLocatorClass">
org.apache.qpid.ra.tm.JBoss7TransactionManagerLocator
</config-property>
<config-property name="TransactionManagerLocatorMethod">
getTm
</config-property>
<connection-definitions>
<connection-definition
class-name="org.apache.qpid.ra.QpidRAManagedConnectionFactory"
jndi-name="QpidJMSXA" pool-name="QpidJMSXA">
<config-property name="connectionURL">
amqp://guest:guest@
/test?brokerlist='tcp://localhost:5672'
</config-property>
<config-property name="SessionDefaultType">
javax.jms.Queue
</config-property>
<xa-pool>
<min-pool-size>10</min-pool-size>
<prefill>false</prefill>
</xa-pool>
<validation>
<background-validation>false</background-validation>
<background-validation-millis>5</background-validation-millis>
</validation>
</connection-definition>
</connection-definitions>
<admin-objects>
<admin-object
class-name="org.apache.qpid.ra.admin.QpidQueueImpl"
jndi-name="jms/iharvest.dragonActivityQpid" use-java-context="false"
pool-name="jms/iharvest.dragonActivityQpid">
<config-property name="destinationAddress">
@qpid.iharvest.queue.dest.address@
</config-property>
</admin-object>
</admin-objects>
</resource-adapter>
</resource-adapters>
</subsystem>
Any thoughts would be appreciated.
Thanks
Joe Daughtery
