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]
