camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Luca Burgazzoli <lburgazz...@gmail.com>
Subject [HEADS UP] Camel clustering bits
Date Wed, 14 Jun 2017 09:36:41 GMT
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

Mime
View raw message