org.apache.s4.comm.tcp
Class TCPRemoteEmitter

java.lang.Object
  extended by org.apache.s4.comm.tcp.TCPEmitter
      extended by org.apache.s4.comm.tcp.TCPRemoteEmitter
All Implemented Interfaces:
Emitter, RemoteEmitter, ClusterChangeListener

public class TCPRemoteEmitter
extends TCPEmitter
implements RemoteEmitter

Emitter to remote subclusters.


Constructor Summary
TCPRemoteEmitter(Cluster topology, int timeout)
          Sends to remote subclusters.
 
Method Summary
 
Methods inherited from class org.apache.s4.comm.tcp.TCPEmitter
close, getPartitionCount, onChange, removeChannel, send
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.s4.base.Emitter
close, getPartitionCount, send
 

Constructor Detail

TCPRemoteEmitter

@Inject
public TCPRemoteEmitter(Cluster topology,
                               int timeout)
                 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