jhberges / camel-consul-leader Goto Github PK

As logged: Session 15e84b22-1f67-b829-1f9c-56fb9a8a3f6a renewed=false

Example from running in "island" mode:

2016-01-28 09:58:43.915  INFO 12476 --- [pool-1-thread-1] j.c.consul.leader.ConsulLeaderElector    : Starting route=poll.es
2016-01-28 09:58:43.916  INFO 12476 --- [pool-1-thread-1] o.a.camel.spring.SpringCamelContext      : Route: poll.es started and consuming from: Endpoint[timer://pollTimer?period=1000]
2016-01-28 09:58:43.916  INFO 12476 --- [pool-1-thread-1] o.a.c.c.controlbus.ControlBusProducer    : ControlBus task done [${camelContext.startRoute("poll.es")}] with result -> void

This repeats for each poll

For example if the route under control has been idle for N MINUTES, then stop route and step down.

This would make it possible to keep other aspiring leaders somewhat lukewarm.

1. Consul sessionKey=Optional[0fef6935-50e1-a2f6-978d-cda039dac10a]
2. 2016/02/10 11:37:06 [WARN] consul.kvs: Rejecting lock of service/xxx/leader due to lock-delay until 2016-02-10 11:37:18.682462267 +0000 UTC
3. 2016/02/10 11:37:23 [ERR] http: Request PUT /v1/kv/service/xxx/leader?acquire=0fef6935-50e1-a2f6-978d-cda039dac10a, error: invalid session "0fef6935-50e1-a2f6-978d-cda039dac10a" from=172.17.0.23:48013