Create a 3 server NoB. Test broker configuration: <?xml version= "1.0" encoding= "UTF-8" ?> <beans xmlns= "http: //www.springframework.org/schema/beans" xmlns:amq= "http: //activemq.apache.org/schema/core" xmlns:p= "http: //www.springframework.org/schema/p" xmlns:context= "http: //www.springframework.org/schema/context" xmlns:xsi= "http: //www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=" http: //www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http: //activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <bean class= "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" > <property name= "properties" > <bean class= "org.fusesource.mq.fabric.ConfigurationProperties" /> </property> </bean> <broker xmlns= "http: //activemq.apache.org/schema/core" brokerName= "${broker.name}" dataDirectory= "${data}" dedicatedTaskRunner= " true " useJmx= " true " persistent= " false " > <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic= ">" producerFlowControl= " true " cursorMemoryHighWaterMark= "100" memoryLimit= "10mb" > <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit= "10" /> </pendingMessageLimitStrategy> </policyEntry> <policyEntry queue= ">" producerFlowControl= " true " cursorMemoryHighWaterMark= "100" memoryLimit= "10mb" > <pendingQueuePolicy> <vmQueueCursor /> </pendingQueuePolicy> <amq:networkBridgeFilterFactory> <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers= " true " /> </amq:networkBridgeFilterFactory> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <managementContext> <managementContext createConnector= " false " /> </managementContext> <networkConnectors> <networkConnector name= "${broker.network.name.1}" uri= "${broker.network.uri.1}" userName= "${broker.username}" password= "${broker.password}" conduitSubscriptions= " false " decreaseNetworkConsumerPriority= " false " networkTTL= "1" > <dynamicallyIncludedDestinations> <queue physicalName= "com.redhat.>" /> </dynamicallyIncludedDestinations> </networkConnector> <networkConnector name= "${broker.network.name.2}" uri= "${broker.network.uri.2}" userName= "${broker.username}" password= "${broker.password}" conduitSubscriptions= " false " decreaseNetworkConsumerPriority= " false " networkTTL= "1" > <dynamicallyIncludedDestinations> <queue physicalName= "com.redhat.>" /> </dynamicallyIncludedDestinations> </networkConnector> </networkConnectors> <amq:persistenceAdapter> <amq:levelDB directory= "${broker.data.dir}" /> </amq:persistenceAdapter> <plugins> <jaasAuthenticationPlugin configuration= "karaf" /> </plugins> <systemUsage> <systemUsage sendFailIfNoSpace= " true " > <memoryUsage> <memoryUsage limit= "64 mb" /> </memoryUsage> <storeUsage> <storeUsage limit= "1 gb" /> </storeUsage> <tempUsage> <tempUsage limit= "500 mb" /> </tempUsage> </systemUsage> </systemUsage> <transportConnectors> <transportConnector name= "${broker.client.transport.name}" uri= "${broker.client.transport.uri}" /> <transportConnector name= "${broker.nob.transport.name}" uri= "${broker.nob.transport.uri}" /> </transportConnectors> </broker> </beans> Deploy camel request/reply route using temp destinations: <camelContext trace= " false " xmlns= "http: //camel.apache.org/schema/blueprint" > <route id= "produce-incoming1" > <from uri= "timer: //productionTimer?fixedRate= true &amp;period=5000" /> <transform> <simple>{{question}}</simple> </transform> <bean ref= "myProducer" method= "produce" /> <log message= "${body}" /> <to uri= "amq:queue:com.redhat.incoming1" /> </route> <route id= "initial-consume-reply1" > <from uri= "amq:queue:com.redhat.incoming1" /> <to uri= "amq:queue:com.redhat.service1?replyToType=Temporary&amp;requestTimeout=35000" pattern= "InOut" /> </route> <route id= "consume-process-reply1" > <from uri= "amq:queue:com.redhat.service1" /> <choice> <when> <simple>${body} contains 'What is your name?' </simple> <transform> <simple>{{name}}!</simple> </transform> <bean ref= "myConsumer" method= "modify" /> </when> <otherwise> <transform> <simple>If you don 't ask me my name, I' m not going to tell you!</simple> </transform> </otherwise> </choice> <log message= "${body}" /> </route> </camelContext>