org.apache.s4.comm.udp
Class UDPEmitter

java.lang.Object
  extended by org.apache.s4.comm.udp.UDPEmitter
All Implemented Interfaces:
Emitter, ClusterChangeListener
Direct Known Subclasses:
UDPRemoteEmitter

public class UDPEmitter
extends java.lang.Object
implements Emitter, ClusterChangeListener

UDP based emitter.


Constructor Summary
UDPEmitter(Cluster topology)
           
 
Method Summary
 void close()
           
 long getMessageDropInQueueCount()
           
 int getPartitionCount()
           
 void onChange()
           
 boolean send(int partitionId, EventMessage eventMessage)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UDPEmitter

@Inject
public UDPEmitter(Cluster topology)
Method Detail

getMessageDropInQueueCount

public long getMessageDropInQueueCount()

send

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

getPartitionCount

public int getPartitionCount()
Specified by:
getPartitionCount in interface Emitter

onChange

public void onChange()
Specified by:
onChange in interface ClusterChangeListener

close

public void close()
Specified by:
close in interface Emitter