public class StreamReceiver extends MessageDecoder
Connection.ConnectionListener
Modifier and Type | Field and Description |
---|---|
(package private) Connection |
connection |
(package private) int |
destStreamID |
(package private) NodeID |
far |
(package private) NodeID |
here |
(package private) int |
sourceStreamID |
Constructor and Description |
---|
StreamReceiver(NodeID here,
NodeID far,
Connection c) |
Modifier and Type | Method and Description |
---|---|
void |
handleStreamDataSend(StreamDataSendMessage msg,
Connection sender)
Handle "Stream Data Send" message
|
void |
handleStreamInitRequest(StreamInitRequestMessage msg,
Connection sender)
Handle "Stream Init Request" message
|
defaultHandler, handleConsumerIdentified, handleDatagram, handleDatagramAcknowledged, handleDatagramRejected, handleIdentifyConsumers, handleIdentifyEvents, handleIdentifyProducers, handleInitializationComplete, handleLearnEvent, handleOptionalIntRejected, handleProducerConsumerEventReport, handleProducerIdentified, handleProtocolIdentificationReply, handleProtocolIdentificationRequest, handleSimpleNodeIdentInfoReply, handleSimpleNodeIdentInfoRequest, handleStreamDataComplete, handleStreamDataProceed, handleStreamInitReply, handleVerifiedNodeIDNumber, handleVerifyNodeIDNumber, put
registerStartNotification
NodeID here
NodeID far
Connection connection
int sourceStreamID
int destStreamID
public StreamReceiver(NodeID here, NodeID far, Connection c)
public void handleStreamInitRequest(StreamInitRequestMessage msg, Connection sender)
handleStreamInitRequest
in class MessageDecoder
public void handleStreamDataSend(StreamDataSendMessage msg, Connection sender)
handleStreamDataSend
in class MessageDecoder
Information on copyright, trademarks and licenses is linked here.
Site hosted by: