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.
send
boolean send(int partitionId,
EventMessage message)
- Parameters:
partitionId
- - destination partitionmessage
- - 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()