Results 1 to 3 of 3

Thread: Setting message properties in AmqpOutboundEndpoint

  1. #1

    Default Setting message properties in AmqpOutboundEndpoint

    I'd like to be able to set priority, etc. on MessageProperties based on properties of the payload object. It appears that the AmqpOutboundEndpoint isn't finished to allow a customized postProcessMethod.

    What would be the best way to accomplish this?

  2. #2
    Join Date
    Oct 2005
    Location
    Boston, MA
    Posts
    2,840

    Default

    You are correct. We need to add a HeaderMapper implementation there that allows for passing Spring Integration Message Header values into the AMQP MessageProperties. Is that what you have in mind?... the actual "priority" value from Spring Integration MessageHeaders.PRIORITY?, or something else?

    In the end, this should be very similar to what we have for our JMS adapters.

  3. #3

    Default

    I'm actually resorting to using a transform before handing messages to the AMQPOutbound adapter. The message object in my specific case already has a priority (aside from the SI priority).

    I noticed the header mapper wasn't there so wanted to bring it up and suggest that the impl should allow overrides for cases like mine where the AMQP header might be set from the message body object as opposed to the header.

Posting Permissions

  • You may not post new threads
  • You may not post replies
  • You may not post attachments
  • You may not edit your posts
  •