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 Summary

Modifier and Type

Method

Description

void

request(int numMessages)

Behaves like Deframer.request(int) except it can be called from any thread.

Methods inherited from interface Deframer
close, closeWhenComplete, deframe, setDecompressor, setFullStreamDecompressor, setMaxInboundMessageSize

Method Details
- 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.