org.apache.s4.base
Interface Emitter

All Known Subinterfaces:
RemoteEmitter
All Known Implementing Classes:
TCPEmitter, TCPRemoteEmitter, UDPEmitter, UDPRemoteEmitter

public interface Emitter

Defines an event emitter, responsible for sending an event to a given partition of the cluster.


Method Summary
 void close()
           
 int getPartitionCount()
           
 boolean send(int partitionId, EventMessage message)
           
 

Method Detail

send

boolean send(int partitionId,
             EventMessage message)
Parameters:
partitionId - - destination partition
message - - message payload that needs to be sent
Returns:
- true - if message is sent across successfully - false - if send fails

getPartitionCount

int getPartitionCount()

close

void close()