Also, from the trace:
> 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}
It appears you are trying to use Qpid JNDI context. When running in the context
of an application server, you would not use the Qpid JNDI implementation, but
the one provided by JBoss. Again, the best place to start would be to review
the JCA example code and the JBoss7 configuration. The example is fully
featured and shows point-to-point/pub-sub and a variety of ways to exercise the
resource adapter.
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]
