mule-config.xml

<flow name="FOO" doc:name="FOO">
  	<amqp:inbound-endpoint exchangeName="FOO-EXCHANGE-V1_0"
			exchangeType="direct" exchangeAutoDelete="false" exchangeDurable="true"
			queueName="FOO-QUEUE" queueDurable="true" queueExclusive="false"
			queueAutoDelete="false" routingKey="FooID">
		</amqp:inbound-endpoint>
		<amqp:acknowledge-message />
		<byte-array-to-string-transformer
			doc:name="Byte Array to String" />
		<idempotent-message-filter storePrefix="Idempotent_Message"
			doc:name="Idempotent Message" idExpression="#[sessionVars['FOO_TRANSACTION_ID']]" />
		<component class="com.redbox.service.DelayingService"
			doc:name="Java" />
		<tracking:custom-event event-name="Fulfillment.BC"
			doc:name="Custom business event">
			<tracking:meta-data key="TRANSACTION_ID"
				value="#[sessionVars['FOO_TRANSACTION_ID']]" />
		</tracking:custom-event>
		<amqp:outbound-endpoint exchange-pattern="one-way"
			exchangeName="Subscription-V1_0" exchangeType="direct"
			exchangeAutoDelete="false" exchangeDurable="true"
			routingKey="FulfillmentIDNotification" />
		<exception-strategy ref="DefaultExceptionStrategy"
			doc:name="Reference Exception Strategy" />

	</flow>