Package org.springframework.kafka.core

Class ABSwitchCluster

java.lang.Object

org.springframework.kafka.core.ABSwitchCluster

All Implemented Interfaces:

Supplier<String>

public class ABSwitchCluster
extends Object
implements Supplier<String>

A Supplier for bootstrap servers that can toggle between 2 lists of servers.

Since:

2.5

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
ABSwitchCluster(String primary, String secondary)	Construct an instance with primary and secondary bootstrap servers.

Method Summary

Modifier and Type	Method	Description
String	get()
boolean	isPrimary()	Get whether or not the primary cluster is active.
void	primary()	Use the primary cluster.
void	secondary()	Use the secondary cluster.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ABSwitchCluster

public ABSwitchCluster(String primary,
 String secondary)

Construct an instance with primary and secondary bootstrap servers.

Parameters:

primary - the primary.

secondary - the secondary.

Method Details

get

public String get()

Specified by:

get in interface Supplier<String>

isPrimary

public boolean isPrimary()

Get whether or not the primary cluster is active.

Returns:

true for primary, false for secondary.

primary

public void primary()

Use the primary cluster.

secondary

public void secondary()

Use the secondary cluster.