Skip to content

Instantly share code, notes, and snippets.

@dannylamb
Created November 29, 2016 19:23
Show Gist options
  • Save dannylamb/0e5b92285960561f09c0652b9a925e4e to your computer and use it in GitHub Desktop.
Save dannylamb/0e5b92285960561f09c0652b9a925e4e to your computer and use it in GitHub Desktop.
<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0"
xsi:schemaLocation="
http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.1.0.xsd
http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
<reference id="broker" interface="org.apache.camel.Component" filter="(osgi.jndi.service.name=acrepo/Broker)"/>
<camelContext xmlns="http://camel.apache.org/schema/blueprint">
<route id="source">
<from uri="timer:foo?period=5000" />
<setHeader headerName="slip"><simple>activemq:queue:testA,activemq:queue:testB</simple></setHeader>
<setExchangePattern pattern="InOut"/>
<routingSlip uriDelimiter=",">
<header>slip</header>
</routingSlip>
<log message="FINISHED: ${body}"/>
</route>
<route id="testA">
<from uri="activemq:queue:testA" />
<transform><simple>DERP</simple></transform>
</route>
<route id="testB">
<from uri="activemq:queue:testB" />
<log message="FROM A: ${body}"/>
<transform><simple>HERP</simple></transform>
</route>
</camelContext>
</blueprint>
Output is....
2016-11-29 19:22:31,085 | DEBUG | sConsumer[testB] | EndpointMessageListener | 58 - org.apache.camel.camel-jms - 2.17.3 | Received Message has JMSCorrelationID [Camel-ID-islandora-deux-40307-1480345698076-14-1583]
2016-11-29 19:22:31,085 | INFO | sConsumer[testB] | testB | 57 - org.apache.camel.camel-core - 2.17.3 | FROM A: DERP
2016-11-29 19:22:31,088 | DEBUG | lyManager[testB] | TemporaryQueueReplyManager | 58 - org.apache.camel.camel-jms - 2.17.3 | Received reply message with correlationID [Camel-ID-islandora-deux-40307-1480345698076-14-1583] -> ActiveMQTextMessage {commandId = 1065, responseRequired = true, messageId = ID:islandora-deux-43373-1480345706310-49:1:1:1:264, originalDestination = queue://testB, originalTransactionId = null, producerId = ID:islandora-deux-43373-1480345706310-49:1:1:1, destination = temp-queue://ID:islandora-deux-43373-1480345706310-49:1:1, transactionId = null, expiration = 0, timestamp = 1480447351086, arrival = 0, brokerInTime = 1480447351087, brokerOutTime = 1480447351087, correlationId = Camel-ID-islandora-deux-40307-1480345698076-14-1583, replyTo = temp-queue://ID:islandora-deux-43373-1480345706310-49:1:1, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@1fdc4725, marshalledProperties = org.apache.activemq.util.ByteSequence@da0e567, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {CamelJmsDeliveryMode=2, firedTime=Tue Nov 29 19:22:31 UTC 2016, breadcrumbId=ID-islandora-deux-40307-1480345698076-14-1579, slip=activemq:queue:testA,activemq:queue:testB}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false, text = HERP}
2016-11-29 19:22:31,088 | DEBUG | lyManager[testB] | TemporaryQueueReplyManager | 58 - org.apache.camel.camel-jms - 2.17.3 | Reply received. OUT message body set to reply payload: HERP
2016-11-29 19:22:31,088 | INFO | lyManager[testB] | source | 57 - org.apache.camel.camel-core - 2.17.3 | FINISHED: HERP
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment