proposal of queueKeeper and default implementation preserving message order 58/2458/1
authorMichal Rehak <mirehak@cisco.com>
Wed, 6 Nov 2013 16:39:00 +0000 (17:39 +0100)
committerMichal Rehak <mirehak@cisco.com>
Wed, 6 Nov 2013 18:34:14 +0000 (19:34 +0100)
commit3c2e39c4036124aa87fa9762d6ddf8ae789be27e
treef4658ac3077d78b64b2d1195760d5a937bc416b4
parent7ee637c4449e773b1e65298e4b75065b0032ba9f
proposal of queueKeeper and default implementation preserving message order

Change-Id: Iba334b48a4909bdfcbecba3113f7c70d296a5964
Signed-off-by: Michal Rehak <mirehak@cisco.com>
14 files changed:
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/ConnectionConductor.java
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/ConnectionConductorFactory.java
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/ConnectionConductorImpl.java
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/SwitchConnectionHandlerImpl.java
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/PopListener.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/QueueKeeper.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/QueueKeeperLightImpl.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/Ticket.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketFinisher.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketImpl.java [new file with mode: 0644]
openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketProcessorFactory.java [new file with mode: 0644]
openflowplugin/src/test/java/org/opendaylight/openflowplugin/openflow/md/core/ConnectionConductorImplTest.java
openflowplugin/src/test/java/org/opendaylight/openflowplugin/openflow/md/core/PopListenerCountingImpl.java [new file with mode: 0644]
openflowplugin/src/test/java/org/opendaylight/openflowplugin/openflow/md/core/session/MessageDispatchServiceImplTest.java