TJMSOUPTPUT to connect the RabbitMQ

kGobu — Sat, 16 Nov 2024 04:26:14 GMT

loaded - rabbitmq-jms-1.11.0.jar, fscontext-4.4.2.jar,amqp-client-4.0.2.jar

for Rabbitmq server (local host) : Enabled the rabbitmq_JMS_topic_exchanges

.bingings : (file content)

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
ConnectionFactory/RefAddr/3/Content=localhost
ConnectionFactory/RefAddr/3/Type=host
ConnectionFactory/RefAddr/3/Encoding=String

Please refer the attached PNG for tjmsouput setting .

and error is :

[statistics] connecting to socket on port 3938
[statistics] connected
[ERROR]: com.rabbitmq.jms.client.RMQSession - RabbitMQ exception on queue declare name(TestQ), durable(true), exclusive(false), auto-delete(false), properties(null)
java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:105)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:101)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:123)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:948)
at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDeclare(AutorecoveringChannel.java:333)
at com.rabbitmq.jms.client.RMQSession.declareRMQQueue(RMQSession.java:879)
at com.rabbitmq.jms.client.RMQSession.createQueue(RMQSession.java:817)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.tDBInput_1Process(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:1173)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.runJobInTOS(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:2067)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.main(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:1877)
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'TestQ' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10)
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:32)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:229)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:117)
... 7 more
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'TestQ' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10)
at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:505)
at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:336)
at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:143)
at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:90)
at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:634)
at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:572)
at java.lang.Thread.run(Unknown Source)
Exception in component tJMSOutput_1 (Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms)
com.rabbitmq.jms.util.RMQJMSException
at com.rabbitmq.jms.client.RMQSession.declareRMQQueue(RMQSession.java:889)
at com.rabbitmq.jms.client.RMQSession.createQueue(RMQSession.java:817)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.tDBInput_1Process(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:1173)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.runJobInTOS(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:2067)
at local_project.copy_of_rabbit_mq_api_call_integration_publish_tjms_0_1.Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.main(Copy_of_Rabbit_MQ_API_Call_Integration_Publish_tjms.java:1877)
Caused by: java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:105)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:101)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:123)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:948)
at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDeclare(AutorecoveringChannel.java:333)
at com.rabbitmq.jms.client.RMQSession.declareRMQQueue(RMQSession.java:879)
... 4 more
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'TestQ' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10)
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:32)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:229)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:117)
... 7 more
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'TestQ' in vhost '/': received none but current is the value 'classic' of type 'longstr', class-id=50, method-id=10)
at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:505)
at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:336)
at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:143)
at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:90)
at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:634)
at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:572)
at java.lang.Thread.run(Unknown Source)
[statistics] disconnected

Re: TJMSOUPTPUT to connect the RabbitMQ

Anonymous — Thu, 17 Oct 2019 08:51:39 GMT

Hello,

It seems this TestQ. queue is not able to be found. Did you configure it?

Best regards

Sabrina

topic Re: TJMSOUPTPUT to connect the RabbitMQ in Talend Studio

TJMSOUPTPUT to connect the RabbitMQ

Re: TJMSOUPTPUT to connect the RabbitMQ