public class DatagramMeteringBuffer extends MessageDecoder
Datagram negative replies cause a local retransmission. Positive replies are reflected upstream to original source of the datagram.
Modifier and Type | Class and Description |
---|---|
(package private) static class |
DatagramMeteringBuffer.Consumer |
(package private) class |
DatagramMeteringBuffer.MessageMemo |
(package private) class |
DatagramMeteringBuffer.ReplyHandler |
Connection.ConnectionListener
Modifier and Type | Field and Description |
---|---|
(package private) DatagramMeteringBuffer.MessageMemo |
currentMemo |
(package private) Connection |
fromDownstream |
(package private) BlockingQueue<DatagramMeteringBuffer.MessageMemo> |
queue |
(package private) static int |
TIMEOUT |
(package private) Connection |
toDownstream |
Constructor and Description |
---|
DatagramMeteringBuffer(Connection toDownstream) |
Modifier and Type | Method and Description |
---|---|
Connection |
connectionForRepliesFromDownstream()
This is where e.g. replies from the OpenLCB
network should be returned to.
|
void |
put(Message msg,
Connection toUpstream)
Accept a datagram message to be sent
|
defaultHandler, handleConsumerIdentified, handleDatagram, handleDatagramAcknowledged, handleDatagramRejected, handleIdentifyConsumers, handleIdentifyEvents, handleIdentifyProducers, handleInitializationComplete, handleLearnEvent, handleOptionalIntRejected, handleProducerConsumerEventReport, handleProducerIdentified, handleProtocolIdentificationReply, handleProtocolIdentificationRequest, handleSimpleNodeIdentInfoReply, handleSimpleNodeIdentInfoRequest, handleStreamDataComplete, handleStreamDataProceed, handleStreamDataSend, handleStreamInitReply, handleStreamInitRequest, handleVerifiedNodeIDNumber, handleVerifyNodeIDNumber
registerStartNotification
static final int TIMEOUT
Connection toDownstream
Connection fromDownstream
DatagramMeteringBuffer.MessageMemo currentMemo
BlockingQueue<DatagramMeteringBuffer.MessageMemo> queue
public DatagramMeteringBuffer(Connection toDownstream)
public Connection connectionForRepliesFromDownstream()
public void put(Message msg, Connection toUpstream)
put
in interface Connection
put
in class MessageDecoder
msg
- Input to be processed by typetoUpstream
- Passed through for specific message processing,
e.g. to send a reply back to the originatorInformation on copyright, trademarks and licenses is linked here.
Site hosted by: