Updated ZeroMQ implementation 27/2227/5
authorTony Tkacik <ttkacik@cisco.com>
Mon, 28 Oct 2013 18:30:40 +0000 (19:30 +0100)
committerEd Warnicke <eaw@cisco.com>
Wed, 6 Nov 2013 20:12:14 +0000 (14:12 -0600)
commit12762ff78528a8e6aa017f78121f13c21a7aea7f
treed6b953847ff2bd9bf744bff5a51d5b6dcbfacb20
parent9139d6ad1d16ba323d5fef0f71fdfde83b679125
Updated ZeroMQ implementation

ZeroMQ implementation listens for rpc service implementations
on one controller node and when new implementation is registered
on controller it announces it via message bus.

The receivers of announcement registers itself as the implementation
of the same service in that node, and delegates actual processing
via message bus to originating controller instance.

This allows for deployment where one controller has a bundle
which provides service A, and other which has bundle which
only consumes service A to cooperate.

Change-Id: If5a2220e05858693db6297a7592893a09021e97d
Signed-off-by: Tony Tkacik <ttkacik@cisco.com>
18 files changed:
opendaylight/md-sal/pom.xml
opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/RpcRouter.java
opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ProviderContextImpl.xtend
opendaylight/md-sal/sal-zeromq-connector/pom.xml [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/Activator.java [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/Message.java [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/RouteIdentifierImpl.java [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/RpcReplyImpl.java [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/RpcRequestImpl.java [new file with mode: 0644]
opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/ZeroMqRpcRouter.java [new file with mode: 0644]
opendaylight/md-sal/test/pom.xml [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-consumer/pom.xml [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-consumer/src/main/java/org/opendaylight/controller/sample/zeromq/consumer/ExampleConsumer.java [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-it/pom.xml [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-it/src/test/java/org/opendaylight/controller/sample/zeromq/test/it/ServiceConsumerController.java [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-it/src/test/java/org/opendaylight/controller/sample/zeromq/test/it/ServiceProviderController.java [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-provider/pom.xml [new file with mode: 0644]
opendaylight/md-sal/test/zeromq-test-provider/src/main/java/org/opendaylight/controller/sample/zeromq/provider/ExampleProvider.java [new file with mode: 0644]