4f4d90376c
Update etcd to use etcd-java which supports v3 API Fix docs Address PR comments Remove unused import Polishing code style.
24 lines
849 B
Markdown
24 lines
849 B
Markdown
SPRING INTEGRATION ETCD SUPPORT
|
|
====================================
|
|
|
|
## ETCD LEADER ELECTION
|
|
|
|
If you need to elect a leader (e.g. for highly available message consumer where only one node should receive messages) you just need to create a `LeaderInitiator`.
|
|
Example:
|
|
|
|
```java
|
|
@Bean
|
|
public EtcdClient etcdClient() {
|
|
return EtcdClient.forEndpoint("localhost",2379).withPlainText().build();
|
|
}
|
|
|
|
@Bean
|
|
public LeaderInitiator initiator() {
|
|
LeaderInitiator initiator = new LeaderInitiator(etcdClient());
|
|
return initiator;
|
|
}
|
|
```
|
|
|
|
Then when a node is elected leader it will send `OnGrantedEvent` to all application listeners.
|
|
See the [Spring Integration User Guide](https://docs.spring.io/spring-integration/reference/html/messaging-endpoints-chapter.html#endpoint-roles) for more information on how to use those events to control messaging endpoints.
|