Module 

Class SynchronizedMessageSourceConduit

    • Constructor Detail

      • SynchronizedMessageSourceConduit

        public SynchronizedMessageSourceConduit​(MessageSourceConduit next)
        Construct a new instance. A new lock object is created.
        Parameters:
        next - the next conduit in the chain
      • SynchronizedMessageSourceConduit

        public SynchronizedMessageSourceConduit​(MessageSourceConduit next,
                                                java.lang.Object lock)
        Construct a new instance.
        Parameters:
        next - the next conduit in the chain
        lock - the lock object to use
    • Method Detail

      • receive

        public int receive​(java.nio.ByteBuffer dst)
                    throws java.io.IOException
        Description copied from interface: MessageSourceConduit
        Receive a message.
        Specified by:
        receive in interface MessageSourceConduit
        Returns:
        the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
        Throws:
        java.io.IOException - if an I/O error occurs
      • receive

        public long receive​(java.nio.ByteBuffer[] dsts,
                            int offs,
                            int len)
                     throws java.io.IOException
        Description copied from interface: MessageSourceConduit
        Receive a message.
        Specified by:
        receive in interface MessageSourceConduit
        offs - the offset into the array of buffers of the first buffer to read into
        len - the number of buffers to fill
        Returns:
        the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
        Throws:
        java.io.IOException - if an I/O error occurs