AMQP Request-Reply

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!