Interface ThreadOptimizedDeframer

  • All Superinterfaces:
    Deframer
    All Known Implementing Classes:
    MigratingThreadDeframer

    public interface ThreadOptimizedDeframer
    extends Deframer
    A Deframer that optimizations by taking over part of the thread safety.
    • Method Detail

      • request

        void request​(int numMessages)
        Behaves like Deframer.request(int) except it can be called from any thread. Must not throw exceptions in case of deframer error.
        Specified by:
        request in interface Deframer
        Parameters:
        numMessages - the requested number of messages to be delivered to the listener.