Well, running this test was one of the ways I was trying to verify it was available.
Then other things that I have done are after starting jboss with "standalone.bat -c standalone-full.xml", I verify that I see the following with no errors: 13:32:33,831 INFO [org.jboss.as.server] (DeploymentScanner-threads - 2) JBAS018 559: Deployed "qpid-ra-0.17.rar" And, then I check the JBoss management console and it shows that it is enabled under Resource Adapters. Is there another way to determine that it is running? Thanks Joe Daughtery On Wed, Jun 6, 2012 at 2:34 PM, Weston M. Price <[email protected]> wrote: > 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] > >
