Benjamin June

unread,

May 3, 2018, 8:47:15 AM5/3/18

to rabbitmq-users

I'm running RabbitMQ3.6.5. Running lower version as Informatica 9.6.1 will need to connect via JMS (that's why I'm not running a newer version as Informatica version per Informatica isn't compatiabile). This is running within a Docker container that resides on a RHEL server.

I try to create an exchange with these specs:

Type - x-jms-topic

Durabilty - Durable (tried Both)

Auto-Delete - no

Internal - no

I click Add Exchange, and I get this error in the browser:

Got response code 500 with body {"error":"Internal Server Error","reason":"{error,\n {exit,\n {{{error,\n {amqp_error,internal_error,\n \"client version 'pre-1.2.0' incompatible with plugin for operation on exchange named 'test'\",\n none}},\n [{rabbit_misc,execute_mnesia_transaction,1,\n [{file,\"src/rabbit_misc.erl\"},{line,553}]},\n {rabbit_misc,execute_mnesia_transaction,2,\n [{file,\"src/rabbit_misc.erl\"},{line,563}]},\n {rabbit_channel,handle_method,3,\n [{file,\"src/rabbit_channel.erl\"},{line,1213}]},\n {rabbit_channel,handle_cast,2,\n [{file,\"src/rabbit_channel.erl\"},{line,457}]},\n {gen_server2,handle_msg,2,\n [{file,\"src/gen_server2.erl\"},{line,1032}]},\n {proc_lib,init_p_do_apply,3,[{file,\"proc_lib.erl\"},{line,247}]}]},\n {gen_server,call,\n [<0.29061.13>,\n {call,\n {'exchange.declare',0,<<\"test\">>,<<\"x-jms-topic\">>,false,\n true,false,false,false,[]},\n none,<0.27871.13>},\n infinity]}},\n [{gen_server,call,3,[{file,\"gen_server.erl\"},{line,212}]},\n {rabbit_mgmt_util,'-amqp_request/5-fun-0-',4,\n [{file,\"src/rabbit_mgmt_util.erl\"},{line,585}]},\n {rabbit_mgmt_util,with_channel,5,\n [{file,\"src/rabbit_mgmt_util.erl\"},{line,604}]},\n {rabbit_mgmt_util,http_to_amqp,5,\n [{file,\"src/rabbit_mgmt_util.erl\"},{line,532}]},\n {webmachine_resource,resource_call,3,\n [{file,\"src/webmachine_resource.erl\"},{line,186}]},\n {webmachine_resource,do,3,\n [{file,\"src/webmachine_resource.erl\"},{line,142}]},\n {webmachine_decision_core,resource_call,1,\n [{file,\"src/webmachine_decision_core.erl\"},{line,48}]},\n {webmachine_decision_core,accept_helper,1,\n [{file,\"src/webmachine_decision_core.erl\"},{line,612}]}]}}\n"}

Also, when I try to connect from Informatica Power Center server, I'm getting the following: (RabbitMQ is most definitely available)

nb5751 : java -jar JMSConnectTest.jar -c com.sun.jndi.fscontext.RefFSContextFactory -p file:/infa_shared/Scripts -j ConnectionFactory -d src-queue -t 1 -n 2 -s 2

Loading jar files:

/usr/local/home/ipcadm96/jmsconnect/javalib/--slf4j-nop-1.7.7.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/amqp-client-4.2.0.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/fscontext-4.5-b29.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/providerutil.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/rabbitmq-client-1.3.0.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/rabbitmq-jms-1.4.7.jar

/usr/local/home/ipcadm96/jmsconnect/javalib/slf4j-api-1.7.7.jar

Loading completed.

JMSException occurred: com.rabbitmq.jms.util.RMQJMSException: RabbitMQ connection was refused. RabbitMQ broker may not be available.

com.rabbitmq.jms.util.RMQJMSException: RabbitMQ connection was refused. RabbitMQ broker may not be available.

at com.rabbitmq.jms.admin.RMQConnectionFactory.getRabbitConnection(RMQConnectionFactory.java:107)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:87)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:72)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createQueueConnection(RMQConnectionFactory.java:270)

at JMSConnectTest.JMSQueueSender(JMSConnectTest.java:93)

at JMSConnectTest.main(JMSConnectTest.java:686)

Caused by: java.net.ConnectException: Connection refused

at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:370)

at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:231)

at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:213)

at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:404)

at java.net.Socket.connect(Socket.java:643)

at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:50)

at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:61)

at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:99)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:918)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:877)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:835)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:987)

at com.rabbitmq.jms.admin.RMQConnectionFactory.getRabbitConnection(RMQConnectionFactory.java:96)

... 5 more

FYI I can connect from Inforrmatica Cloud Services, so firewall and access isn't an issue. The RabbitMQ console comes up, and is working.... just these components aren't and I'm nopt sure why. Anyone help?

Arnaud Cogoluègnes

unread,

May 3, 2018, 9:19:03 AM5/3/18

to rabbitm...@googlegroups.com

For the exchange creation, this is a known issue before RabbitMQ 3.6.6 [1]. You should upgrade to at least 3.6.6, or even better 3.6.15 or 3.7.4). See the thread [2] mentioned in the issue for more information.

For the connection error, the client cannot connect to the broker. It's hard to tell more without the code and the configuration you're using (JMSConnectTest.jar and the configuration file are unknown to us). You can have a look at [3] for common client resolution problems.

[1] https://github.com/rabbitmq/rabbitmq-jms-topic-exchange/issues/9
[2] https://groups.google.com/forum/#!topic/rabbitmq-users/QmrIP7AzhFA
[3] http://www.rabbitmq.com/networking.html#dns

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Benjamin June

unread,

May 3, 2018, 9:32:45 AM5/3/18

to rabbitm...@googlegroups.com, l.g...@neu.edu, h.ng...@neu.edu

Hi Arnaud,

Thanks for the response. I've cc'd a couple colleagues here.

We are using 3.6.5 because Informatica support told us they don't support 3.7.4. I guess we can try that... Leo, can you run that by Informatica?

Also, we'll review the attached links. I've pasted our bindings file below. JMSConnectTest.jar is a file that informatica suggests to use to test connection to our broker. That is here FYI:

https://marketplace.informatica.com/solutions/informatica_jms_connection_test

nb5751 : more /infa_shared/Scripts/.bindings

# -----.bindings file------------------------------------------------------------------

#ConnectionFactory/ClassName=com.rabbitmq.jms.admin.RMQConnectionFactory

ConnectionFactory/ClassName=javax.jms.ConnectionFactory

ConnectionFactory/FactoryName=com.rabbitmq.jms.admin.RMQObjectFactory

ConnectionFactory/RefAddr/0/Content=jms/ConnectionFactory

ConnectionFactory/RefAddr/0/Type=name

ConnectionFactory/RefAddr/0/Encoding=String

ConnectionFactory/RefAddr/1/Content=javax.jms.ConnectionFactory

ConnectionFactory/RefAddr/1/Type=type

ConnectionFactory/RefAddr/1/Encoding=String

ConnectionFactory/RefAddr/2/Content=com.rabbitmq.jms.admin.RMQObjectFactory

ConnectionFactory/RefAddr/2/Type=factory

ConnectionFactory/RefAddr/2/Encoding=String

# Change this line accordingly if the broker is not at localhost

ConnectionFactory/RefAddr/3/Content=155.33.23.216 8084

ConnectionFactory/RefAddr/3/Type=host

ConnectionFactory/RefAddr/3/Encoding=String

# -------------------------------------------------------------------------------------

#amqp.hold.set/ClassName=com.rabbitmq.jms.admin.RMQDestination

amqp.hold.set/ClassName=javax.jms.Queue

amqp.hold.set/FactoryName=com.rabbitmq.jms.admin.RMQObjectFactory

amqp.hold.set/RefAddr/0/Content=jms/Queue

amqp.hold.set/RefAddr/0/Type=name

amqp.hold.set/RefAddr/0/Encoding=String

amqp.hold.set/RefAddr/1/Content=javax.jms.Queue

amqp.hold.set/RefAddr/1/Type=type

amqp.hold.set/RefAddr/1/Encoding=String

amqp.hold.set/RefAddr/2/Content=com.rabbitmq.jms.admin.RMQObjectFactory

amqp.hold.set/RefAddr/2/Type=factory

amqp.hold.set/RefAddr/2/Encoding=String

amqp.hold.set/RefAddr/3/Content=amqp.hold.set

amqp.hold.set/RefAddr/3/Type=destinationName

amqp.hold.set/RefAddr/3/Encoding=String

# src-queue------------------------------------------------------------------------------

#src-queue/ClassName==com.rabbitmq.jms.admin.RMQDestination

src-queue/ClassName=javax.jms.Queue

src-queue/FactoryName=com.rabbitmq.jms.admin.RMQObjectFactory

src-queue/RefAddr/0/Content=jms/Queue

src-queue/RefAddr/0/Type=name

src-queue/RefAddr/0/Encoding=String

src-queue/RefAddr/1/Content=javax.jms.Queue

src-queue/RefAddr/1/Type=type

src-queue/RefAddr/1/Encoding=String

src-queue/RefAddr/2/Content=com.rabbitmq.jms.admin.RMQObjectFactory

src-queue/RefAddr/2/Type=factory

src-queue/RefAddr/2/Encoding=String

src-queue/RefAddr/3/Content=src-queue

src-queue/RefAddr/3/Type=destinationName

src-queue/RefAddr/3/Encoding=String

src-queue/RefAddr/4/Content=true

src-queue/RefAddr/4/Type=amqp

src-queue/RefAddr/4/Encoding=String

src-queue/RefAddr/5/Content=priorityQ

src-queue/RefAddr/5/Type=amqpQueueName

src-queue/RefAddr/5/Encoding=String

src-queue/RefAddr/6/Content=

src-queue/RefAddr/6/Type=amqpExchangeName

src-queue/RefAddr/6/Encoding=String

src-queue/RefAddr/7/Content=priorityQ

src-queue/RefAddr/7/Type=amqpRoutingKey

src-queue/RefAddr/7/Encoding=String

To post to this group, send email to rabbitm...@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

- Ben

Benjamin June

unread,

May 3, 2018, 9:33:35 AM5/3/18

to rabbitm...@googlegroups.com, l.g...@neu.edu, h.ng...@neu.edu

One more reply.. this outlines everything we've done to date to solve this:

Here is what I’ve done so far:

Found the INFA knowledge base article: https://kb.informatica.com/howto/6/Pages/17/333913.aspx?myk=rabbitmq

- From Step 1 requested to enable rabbitmq_jms_topic_exchange plugin on both 3.6.5 and 3.7.4

- All of Step 2:

o The jar file version are different as the KB had an older RMQ version. They are stored in $INFA_HOME/server/bin/javalib on nb5751.neu.edu:

o .bindings file is in /infa_shared/Scripts directory (currently points to v3.6.5 but tried with v3.7.4 with the same result)

o Configured both JNDI and JMS connections on REPO_DEV (JNDI_RabbitMQ_Dev & JMS_RabbitMQ_AmqpHoldSet_Dev) – use .bindings above.

- Created a workflow that would put a message on a pre-configured queue.

§ / ~vmunagandla /Workflows/wf_m_Test_AMQP_Message

- Ran the workflow which produced the error below:

Severity: ERROR

Timestamp: 5/2/2018 11:42:39 AM

Node: node01dev

Thread: WRITER_1_*_1

Process ID: 1638658

Message Code: JMS_3003

Message: [ERROR] Cannot create writer connection: Failed to create JMS connection: connect timed outException Stack: com.rabbitmq.jms.util.RMQJMSException: connect timed out

at com.rabbitmq.jms.admin.RMQConnectionFactory.getRabbitConnection(RMQConnectionFactory.java:109)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:87)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:72)

at com.rabbitmq.jms.admin.RMQConnectionFactory.createQueueConnection(RMQConnectionFactory.java:270)

at com.informatica.powerconnect.jms.server.common.PlginJMSConnection$PlginJMSQueueConnection.createConnection(PlginJMSConnection.java:378)

at com.informatica.powerconnect.jms.server.common.PlginJMSConnection.<init>(PlginJMSConnection.java:93)

at com.informatica.powerconnect.jms.server.common.PlginJMSConnection$PlginJMSQueueConnection.<init>(PlginJMSConnection.java:355)

at com.informatica.powerconnect.jms.server.common.PlginJMSConnection.create(PlginJMSConnection.java:118)

at com.informatica.powerconnect.jms.server.writer.JMSWriterConn.init(JMSWriterConn.java:93)

Caused by: java.net.SocketTimeoutException: connect timed out

at java.net.PlainSocketImpl.socketConnect(Native Method)