Mailing-List: contact dev-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@camel.apache.org
MIME-Version: 1.0
From: Luca Burgazzoli <lburgazzoli@gmail.com>
Date: Wed, 14 Jun 2017 11:36:41 +0200
Message-ID: <CAMpNYoYrVrq=ygNAsm=S_r82rZqpb3P3ZHXvp_-wmCc6MocAoA@mail.gmail.com>
Subject: [HEADS UP] Camel clustering bits
To: dev@camel.apache.org
Content-Type: text/plain; charset="UTF-8"
archived-at: Wed, 14 Jun 2017 09:36:51 -0000

Hello,

I've been working on CAMEL-11362 to create a leader election service
in recent times and I've ended up with some initial bits of a
potential clustering service for Camel [1].

So fare there are a few simple interfaces:
- CamelClusterService
- CamelClusterView
- CamelClusterMember

The CamelClusterService is just a regular camel service and is
responsible to create views of the cluster; a view is like a "group"
with its own set of resources like a leader/services/etc and i.e.
broadcast of messages should not go beyond its borders, etc; how the
view is mapped then depends on the underlying technology used so it
can be a group in atomix/jgroups, a path in zk/etcd, a map in
hazelcast/infinispan, etc.

As today the View API is limited to leader election and topology
events (member joining/leaving the view) and I've build a generic
RoutePolicy and RoutePolicyFactory on top of them [2][3]. A future
work may be to add support for service discovery, load balancing ad
more.

I also started the implementation of camel-atomix based on the
atomix.io project which offers some easy to use APIs for distributed
systems so an implementation of the API can be found here [4] and a
test here [5].


Feedback is very welcome.


[1] https://github.com/lburgazzoli/apache-camel/tree/CAMEL-11362/camel-core/src/main/java/org/apache/camel/ha
[2] https://github.com/lburgazzoli/apache-camel/blob/CAMEL-11362/camel-core/src/main/java/org/apache/camel/impl/ha/ClusteredRoutePolicy.java
[3] https://github.com/lburgazzoli/apache-camel/blob/CAMEL-11362/camel-core/src/main/java/org/apache/camel/impl/ha/ClusteredRoutePolicyFactory.java
[4] https://github.com/lburgazzoli/apache-camel/tree/CAMEL-11362/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/ha
[5] https://github.com/lburgazzoli/apache-camel/blob/CAMEL-11362/components/camel-atomix/src/test/java/org/apache/camel/component/atomix/ha/AtomixRoutePolicyTest.java


---
Luca Burgazzoli