Are those deployables available for download? If so, where might I get them? I am hoping that I don't have to download the svn repo b/c I have limited space.
Thanks Joe On Wed, Jun 6, 2012 at 2:46 PM, Weston M. Price <[email protected]> wrote: > Hi Joe, > Also, I would recommend running the JBoss7 example from the JCA > example set. It's a good place to start to getting things up and running > before replacing things with your own configuration. > > Regards, > > Weston > On Jun 6, 2012, at 2:34 PM, Weston M. Price 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] > > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > >
