How does the exchange-name-expression on an amqp outbound channel work ?

[kunlenzo247]

I have my destination AMQP exchange name in the header, and I want to use the exchange-expression-name on an outbound channel adapter to dynamically send to different exchanges.

<int:channel id="amqpOutboundChannel"/>
<int-amqp:outbound-channel-adapter channel="amqpOutboundChannel" exchange-name-expression="headers['out.workQ']" routing-key="simpleKey" mapped-request-headers="embed.*"/>

But I get the exception below -

Caused by: org.springframework.integration.MessagingException: failed to resolve channel name 'ORDER.XCHG'
	at org.springframework.integration.router.AbstractMappingMessageRouter.resolveChannelForName(AbstractMappingMessageRouter.java:168)
	at org.springframework.integration.router.AbstractMappingMessageRouter.addChannelFromString(AbstractMappingMessageRouter.java:197)

Any idea what I might be doing wrong ?

[kunlenzo247]

I found out the problem was with an upstream component (router).

Thanks.

I have my destination AMQP exchange name in the header, and I want to use the exchange-expression-name on an outbound channel adapter to dynamically send to different exchanges.

<int:channel id="amqpOutboundChannel"/>
<int-amqp:outbound-channel-adapter channel="amqpOutboundChannel" exchange-name-expression="headers['out.workQ']" routing-key="simpleKey" mapped-request-headers="embed.*"/>

But I get the exception below -

Caused by: org.springframework.integration.MessagingException: failed to resolve channel name 'ORDER.XCHG'
	at org.springframework.integration.router.AbstractMappingMessageRouter.resolveChannelForName(AbstractMappingMessageRouter.java:168)
	at org.springframework.integration.router.AbstractMappingMessageRouter.addChannelFromString(AbstractMappingMessageRouter.java:197)

Any idea what I might be doing wrong ?