How to send reply message in spring rabbit correctly?

Question

I have a spring rabbit listener

@Override
public void onMessage(Message message, Channel channel) {
     //do something

      channel.basicPublish("",queue name, null, SerializationUtils.serialize(r));

}

How rabbit will understand that this response is for my particular message? In case if I have a thousands of messages. What I need to do to link request and response? And is there a way to pass to the channel POJO without serialization? Thanks

Artem Bilan · Accepted Answer · 2015-04-22 14:05:53Z

2

You should take care there about replyTo and correlation.

But I'd say that there is no reason to do that manually, because MessageListenerAdapter takes care about that.

You just need supply a POJO with request-reply capabilities:

class Delegate {
    @SuppressWarnings("unused")
    public String handleMessage(String input) {
        called.set(true);
        return "processed" + input;
    }
}

adapter.setDelegate(new Delegate());

answered Apr 22, 2015 at 14:05

Artem Bilan

123k11 gold badges103 silver badges130 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

avalon Over a year ago

Thank you ,so in other words, I need to send my object with boolean flag to the consumer, consumer sets this flag to true and pulls back, right? Should be this flag attribute be thread safe? Thanks

Artem Bilan Over a year ago

Sorry, I don't understand what you talk about. The POJO consumer (Delegate) is just responsible to get deal with domain object and knows nothing about AMQP (e.g. Channel). No need to send any boolean flag. Just send Message as is with desired body (template.convertSendAndReceive) and your POJO should accept the domain object as method argument and can return another domain. The MessageListenerAdapter will take care about conversions. SimpleMessageConverter is used by default.

avalon Over a year ago

Thanks, sorry but I was confused a bit because I did the same from the beginning: return new MessageListenerAdapter(orderSaverListener); So if I understood correctly, I should not care about corellationIDS and so on, and in this question description I should not do anything,right?

Artem Bilan Over a year ago

Looks like. At least it works that way in the SimpleMessageListenerContainer: docs.spring.io/spring-amqp/docs/latest-ga/reference/html/…

Collectives™ on Stack Overflow

How to send reply message in spring rabbit correctly?

1 Answer 1

4 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

4 Comments

Your Answer

Sign up or log in

Post as a guest

Related