You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@celix.apache.org by rlenferink <gi...@git.apache.org> on 2016/12/22 12:40:04 UTC
[GitHub] celix pull request #12: CELIX-389: Added publisher/subscriber implementation
GitHub user rlenferink opened a pull request:
https://github.com/apache/celix/pull/12
CELIX-389: Added publisher/subscriber implementation
Added the publisher / subscriber implementation which is based on the concepts of the remote service
admin (i.e. rsa / topology / discovery pattern).
Publishers are senders of data, subscribers can receive data. Publishers can publish/send data to certain channels (called 'topics' further on), subscribers can subscribe to these topics. For every topic a publisher service is created by the pubsub admin. This publisher is announced through etcd. So etcd is used for discovery of the publishers. Subscribers are also registered as a service by the pubsub admin and will watch etcd for changes and when a new publisher is announced, the subscriber will check if the topic matches its interests. If the subscriber is interested in/subscribed to a certain topic, a connection between publisher and subscriber will be instantiated by the pubsub admin.
The dfi library is used for message serialization. The publisher / subscriber implementation will arrange that every message which will be send gets an unique id.
For communication between publishers and subscribers UDP and ZeroMQ can be used. When using ZeroMQ it's also possible to setup a secure connection to encrypt the traffic being send between publishers and subscribers. This connection can be secured with ZeroMQ by using a curve25519 key pair per topic.
The publisher/subscriber implementation supports sending of a single message and sending of multipart messages.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rlenferink/celix pubsub
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/celix/pull/12.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #12
----
commit 701eae493f0299c73bec9fe4f944734b881654bb
Author: Roy Lenferink <le...@gmail.com>
Date: 2016-12-22T12:34:38Z
CELIX-389: Added publisher/subscriber implementation
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] celix pull request #12: CELIX-389: Added publisher/subscriber implementation
Posted by rlenferink <gi...@git.apache.org>.
Github user rlenferink closed the pull request at:
https://github.com/apache/celix/pull/12
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---