org.apache.s4.comm.udp
Class UDPRemoteEmitter

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

public class UDPRemoteEmitter
extends UDPEmitter

UDP-based emitter for sending events to remote clusters.


Constructor Summary
UDPRemoteEmitter(Cluster topology)
          Sends to remote subclusters.
 
Method Summary
 
Methods inherited from class org.apache.s4.comm.udp.UDPEmitter
close, getMessageDropInQueueCount, getPartitionCount, onChange, send
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UDPRemoteEmitter

@Inject
public UDPRemoteEmitter(Cluster topology)
                 throws java.lang.InterruptedException
Sends to remote subclusters. This is dynamically created, through an injected factory, when new subclusters are discovered (as remote streams outputs)

Throws:
java.lang.InterruptedException