
Questions: 23,716 //
Answers: 52,286 //
Contributing Members: 17,985
I'm facing given below error with AMQP Connector having Request-Reply block under Mule Clustered environment (No issues with the single node Mule server).
org.mule.lifecycle.AbstractLifecycleManager - Disposing: 'amqpConnector.dispatcher.206782451'. Object is: Dispatcher 2017-02-16 21:23:30,078 [amqpReceiver.09] ERROR org.mule.exception.CatchMessagingExceptionStrategy - ******************************************************************************** Message : org.mule.api.serialization.SerializationException: Could not serialize object (com.hazelcast.nio.serialization.HazelcastSerializationException). Message payload is of type: byte[] Code : MULE_ERROR--2 -------------------------------------------------------------------------------- Exception stack is: 1. com.rabbitmq.client.impl.ChannelN (java.io.NotSerializableException) java.io.ObjectOutputStream:1184 (null) 2. java.io.NotSerializableException: com.rabbitmq.client.impl.ChannelN (org.apache.commons.lang.SerializationException) org.apache.commons.lang.SerializationUtils:111 (null) 3. Could not serialize object (org.mule.api.serialization.SerializationException) org.mule.serialization.internal.AbstractObjectSerializer:68 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/serialization/SerializationException.html) 4. org.mule.api.serialization.SerializationException: Could not serialize object (com.hazelcast.nio.serialization.HazelcastSerializationException) com.hazelcast.nio.serialization.SerializationServiceImpl:295 (null) 5. org.mule.api.serialization.SerializationException: Could not serialize object (com.hazelcast.nio.serialization.HazelcastSerializationException). Message payload is of type: byte[] (org.mule.api.MessagingException) org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor:32 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html) -------------------------------------------------------------------------------- Root Exception stack trace: java.io.NotSerializableException: com.rabbitmq.client.impl.ChannelN at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548) at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509) + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything) ********************************************************************************
Here is AMQP Connector configuration:
<amqp:connector name="amqpConnector"
doc:name="AMQP-0-9 Connector"
host="${amqp.host}"
port="${amqp.port}"
virtualHost="${amqp.virtualHost}"
ackMode="MULE_AUTO"
activeDeclarationsOnly="true"
mandatory="true"
prefetchCount="1"
priority="6"
username="${amqp.username}"
password="${amqp.password}">
<reconnect-forever frequency="9000" />
<service-overrides sessionHandler="org.mule.session.NullSessionHandler"/>
</amqp:connector>
And here is a Request-reply block:
<request-reply doc:name="Request-Reply" timeout="${amqp.reqreply.timeout}">
<amqp:outbound-endpoint exchangeName="${amqp.exchange.name}"
routingKey="${amqp.routing.inc.get.reqst}"
connector-ref="amqpConnector"
exchangeType="direct"
exchangeDurable="true" exchangeAutoDelete="false"
queueDurable="true"
responseTimeout="10000"
doc:name="AMQP-Outbound">
<message-properties-transformer doc:name="Message Properties">
<add-message-property key="client" value="#[flowVars.clientVar]"/>
</message-properties-transformer>
</amqp:outbound-endpoint>
<amqp:inbound-endpoint
queueName="${amqp.queue.inc.get.reply}"
connector-ref="amqpConnector"
doc:name="AMQP-Inbound">
</amqp:inbound-endpoint>
</request-reply>
Any help/suggestion is highly appreciated. Thanks in advance!
AMQP create queues/exchanges 1 Answer
cannot fetch from the amqp queue (using mulerequester) 1 Answer
setting amqp consumer count 2 Answers