Class BlockEnabledSenderBase<H>

    • Constructor Detail

      • BlockEnabledSenderBase

        public BlockEnabledSenderBase()
    • Method Detail

      • sendMessage

        public final SenderResult sendMessage​(Message message,
                                              PipeLineSession session)
                                       throws SenderException,
                                              TimeoutException
        Description copied from interface: ISender
        Send a message to some destination (as configured in the Sender object). This method may only be called after the configure() method is called.

        The following table shows the difference between synchronous and a-synchronous senders:

         synchronousa-synchronous
        ISender.isSynchronous() returnstruefalse
        return value of sendMessage() isthe reply-messagethe messageId of the message sent
        the correlationID specified with sendMessage()may be ignoredis sent with the message
        a {link TimeOutException}may be thrown if a timeout occurs waiting for a replyshould not be expected

        Multiple objects may try to call this method at the same time, from different threads. Implementations of this method should therefore be thread-safe, or synchronized.

        Specified by:
        sendMessage in interface ISender
        Throws:
        SenderException
        TimeoutException