public class EventFilterGateway extends Gateway
Provides two connections, called "East" and "West"
Filtering algorithm is simple:
Once a "ConsumerIdentified" message for a particular EventID
comes from one side,
ProducedConsumerEventReport messages with that EventID are
forwarded to that side.
Modifier and Type | Class and Description |
---|---|
(package private) class |
EventFilterGateway.EastConnection |
(package private) class |
EventFilterGateway.WestConnection |
Connection.ConnectionListener
Modifier and Type | Field and Description |
---|---|
(package private) HashSet<EventID> |
idsGoingEast |
(package private) HashSet<EventID> |
idsGoingWest |
eastInputConnection, eastOutputConnection, westInputConnection, westOutputConnection
Constructor and Description |
---|
EventFilterGateway() |
Modifier and Type | Method and Description |
---|---|
Connection |
getEastConnection()
Provide a connection object for use by
the East node.
|
Connection |
getWestConnection()
Provide a connection object for use by
the West node.
|
registerEast, registerWest, sendMessageToEast, sendMessageToWest
defaultHandler, handleConsumerIdentified, handleDatagram, handleDatagramAcknowledged, handleDatagramRejected, handleIdentifyConsumers, handleIdentifyEvents, handleIdentifyProducers, handleInitializationComplete, handleLearnEvent, handleOptionalIntRejected, handleProducerConsumerEventReport, handleProducerIdentified, handleProtocolIdentificationReply, handleProtocolIdentificationRequest, handleSimpleNodeIdentInfoReply, handleSimpleNodeIdentInfoRequest, handleStreamDataComplete, handleStreamDataProceed, handleStreamDataSend, handleStreamInitReply, handleStreamInitRequest, handleVerifiedNodeIDNumber, handleVerifyNodeIDNumber, put
registerStartNotification
public Connection getEastConnection()
getEastConnection
in class Gateway
public Connection getWestConnection()
getWestConnection
in class Gateway
Information on copyright, trademarks and licenses is linked here.
Site hosted by: