org.apache.s4.core
Class RemoteStream
java.lang.Object
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
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 |
key
protected final Key<Event> key
RemoteStream
public RemoteStream(App app,
java.lang.String name,
KeyFinder<Event> finder,
RemoteSenders remoteSenders,
Hasher hasher,
RemoteStreams remoteStreams,
java.lang.String clusterName)
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>