public static class Sender.ConfirmSendContext<OMSG extends OutboundMessage> extends Sender.SendContext<OMSG>
channel, message
Modifier | Constructor and Description |
---|---|
protected |
ConfirmSendContext(Channel channel,
OMSG message,
reactor.rabbitmq.Sender.PublishConfirmSubscriber<OMSG> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
publish() |
void |
publish(OutboundMessage outboundMessage) |
getChannel, getMessage
public void publish(OutboundMessage outboundMessage) throws Exception
publish
in class Sender.SendContext<OMSG extends OutboundMessage>
Exception
public void publish() throws Exception
publish
in class Sender.SendContext<OMSG extends OutboundMessage>
Exception