org.apache.s4.base
Interface Listener

All Known Implementing Classes:
TCPListener, UDPListener

public interface Listener

Get a byte array received by a lower level layer.


Method Summary
 void close()
           
 int getPartitionId()
           
 byte[] recv()
          Perform blocking receive on the appropriate communication channel
 

Method Detail

recv

byte[] recv()
Perform blocking receive on the appropriate communication channel

Returns:
  • byte[] message returned by the channel
  • null if the associated blocking thread is interrupted

getPartitionId

int getPartitionId()

close

void close()