Hi Joey,
From the stacktracce, this looks like as simple connectivity error:
> 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
So, it appears that your broker is not running at this address and this port.
Simple question, have you verified that your broker is running and is
reachable?
Regards,
Weston
On Jun 6, 2012, at 12:40 PM, Joey Daughtery wrote:
> 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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
