Facing issue while building a producer and consumer route for Rabittmq

[Anonymous]

Hi Team,

I am facing issue while creating a route for sending a message or consuming a message from rabbitmq. I have gone through various options provided on Talend community but could not fix it.

Approach 1:

Where cMQConnectFactory is having AMQP server trying to connect localhost at port 5672 and component cAMQP is having URI type as queue.

getting error -

----------------------------------------------------------

Starting job consumer_message at 22:45 07/07/2019.

[statistics] connecting to socket on port 3947
[statistics] connected
[ERROR]: org.apache.qpid.jms.JmsConnection - Failed to connect to remote at: amqp://localhost:5672
[ERROR]: org.apache.camel.processor.DefaultErrorHandler - Failed delivery for (MessageId: ID-DESKTOP-Q42VT4K-1562535919141-0-2 on ExchangeId: ID-DESKTOP-Q42VT4K-1562535919141-0-1). Exhausted after delivery attempt: 1 caught: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: An existing connection was forcibly closed by the remote host

Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor Elapsed (ms)
[consumer_message_c] [consumer_message_c] [timer://cTimer_1?delay=1000&repeatCount=5 ] [ 855]
[consumer_message_c] [consumer_message_c] [setBody[simple{HELLO}] ] [ 18]
[consumer_message_c] [consumer_message_c] [cMQConnectionFactory1:queue:testq ] [ 831]

Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: An existing connection was forcibly closed by the 

-------------------------------------------------------------------------

Approach 2:

Where cMessagingEndPoint is having URL as

"rabbitmq://localhost:15672/testex?username=guest&password=guest"

but getting error -

-----------------------------------------------------------

Starting job consumer_message2 at 22:52 07/07/2019.

[statistics] connecting to socket on port 3418
[statistics] connected
org.apache.camel.FailedToCreateRouteException: Failed to create route consumer_message2_cMessagingEndpoint_1: Route(consumer_message2_cMessagingEndpoint_1)[[From[rabbitmq... because of Failed to resolve endpoint: rabbitmq://localhost:15672/testex?password=guest&username=guest due to: No component found with scheme: rabbitmq
org.apache.camel.RuntimeCamelException: org.apache.camel.FailedToCreateRouteException: Failed to create route consumer_message2_cMessagingEndpoint_1: Route(consumer_message2_cMessagingEndpoint_1)[[From[rabbitmq... because of Failed to resolve endpoint: rabbitmq://localhost:15672/testex?password=guest&username=guest due to: No component found with scheme: rabbitmq
at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1826)

------------------------------------------------------------------------

Really appreciate your quick help on this.

[Anonymous]

I am stuck with this issue and cannot proceed. Your quick help will be really great here.