Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <parent>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-parent</artifactId>
- <version>1.5.10.RELEASE</version>
- </parent>
- <dependency>
- <groupId>org.springframework.integration</groupId>
- <artifactId>spring-integration-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.integration</groupId>
- <artifactId>spring-integration-jdbc</artifactId>
- </dependency>
- @Configuration
- public class LeaderElectionConfiguration {
- @Bean
- public LockRegistry lockRegistry(LockRepository lockRepository) {
- return new JdbcLockRegistry(lockRepository);
- }
- @Bean
- public DefaultLockRepository lockRepository(DataSource dataSource) {
- return new DefaultLockRepository(dataSource);
- }
- @Bean
- public LockRegistryLeaderInitiator leaderInitiator(LockRegistry lockRegistry) {
- LockRegistryLeaderInitiator lockRegistryLeaderInitiator = new LockRegistryLeaderInitiator(lockRegistry);
- lockRegistryLeaderInitiator.start();
- return lockRegistryLeaderInitiator;
- }
- spring:
- datasource:
- initialize: false
- url: jdbc:mysql://localhost:3306/whatever
- username: admin
- password: adminpw
- driver-class-name: com.mysql.cj.jdbc.Driver
Add Comment
Please, Sign In to add comment