|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.s4.core.Receiver
public class Receiver
The Receiver
and its counterpart Sender
are the top level classes of the communication layer.
Receiver
is responsible for receiving an event to a ProcessingElement
instance using a hashKey.
A Listener implementation receives data from the network and passes an event as a byte array to the Receiver
.
The byte array is de-serialized and converted into an Event
. Finally the event is passed to the matching
streams.
Receiver
instance per node.
Details on how the cluster is partitioned and how events are serialized and transmitted to its destination are hidden
from the application developer.
Constructor Summary | |
---|---|
Receiver(Listener listener,
SerializerDeserializer serDeser)
|
Method Summary | |
---|---|
void |
close()
|
void |
run()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
@Inject public Receiver(Listener listener, SerializerDeserializer serDeser)
Method Detail |
---|
public void run()
run
in interface java.lang.Runnable
public void close()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |