Class AbstractDecodedMessageSink

All Implemented Interfaces:
Direct Known Subclasses:
AbstractDecodedMessageSink.Basic, AbstractDecodedMessageSink.Stream

public abstract class AbstractDecodedMessageSink extends Object implements MessageSink
  • Constructor Details

    • AbstractDecodedMessageSink

      public AbstractDecodedMessageSink(CoreSession coreSession, MethodHandle methodHandle)
  • Method Details

    • accept

      public void accept(Frame frame, Callback callback)
      Description copied from interface: MessageSink
      Consume the frame payload to the message.
      Specified by:
      accept in interface MessageSink
      frame - the frame, its payload (and fin state) to append
      callback - the callback for how the frame was consumed
    • fail

      public void fail(Throwable failure)
      Description copied from interface: MessageSink

      Fail the message sink.

      Release any resources and fail all stored callbacks as MessageSink.accept(Frame, Callback) will never be called again.

      Specified by:
      fail in interface MessageSink
      failure - the failure that occurred.