org.apache.s4.core
Class RemoteStream

java.lang.Object
  extended by org.apache.s4.core.RemoteStream
All Implemented Interfaces:
Streamable<Event>

public class RemoteStream
extends java.lang.Object
implements Streamable<Event>

Stream that dispatches events to interested apps in remote clusters


Field Summary
protected  Key<Event> key
           
 
Constructor Summary
RemoteStream(App app, java.lang.String name, KeyFinder<Event> finder, RemoteSenders remoteSenders, Hasher hasher, RemoteStreams remoteStreams, java.lang.String clusterName)
           
 
Method Summary
 void close()
          Stop and close all the streams.
 java.lang.String getName()
           
 void put(Event event)
          Put an event into the streams.
 void start()
          Starting the stream starts the associated dequeuing thread.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

key

protected final Key<Event> key
Constructor Detail

RemoteStream

public RemoteStream(App app,
                    java.lang.String name,
                    KeyFinder<Event> finder,
                    RemoteSenders remoteSenders,
                    Hasher hasher,
                    RemoteStreams remoteStreams,
                    java.lang.String clusterName)
Method Detail

put

public void put(Event event)
Description copied from interface: Streamable
Put an event into the streams.

Specified by:
put in interface Streamable<Event>

getName

public java.lang.String getName()
Specified by:
getName in interface Streamable<Event>
Returns:
the name of this streamable object.

start

public void start()
Description copied from interface: Streamable
Starting the stream starts the associated dequeuing thread.

Specified by:
start in interface Streamable<Event>

close

public void close()
Description copied from interface: Streamable
Stop and close all the streams.

Specified by:
close in interface Streamable<Event>