software.chronicle.datagrid.internal.queue

Class MapControlledQueueSwitcher<T,M>

java.lang.Object

software.chronicle.datagrid.internal.queue.MapControlledQueueSwitcher<T,M>

All Implemented Interfaces:

Closeable, AutoCloseable, QueueSwitcher<T,M>

public final class MapControlledQueueSwitcher<T,M>
extends Object
implements QueueSwitcher<T,M>

Constructor Summary

Constructors

Constructor and Description
MapControlledQueueSwitcher(@NotNull Asset asset, @NotNull QueueCfg queueCfg, @NotNull Map<Byte,QueueProxyReplica> replicas, @NotNull MapView<CharSequence,Byte> controlMap, @NotNull String masterIdKey, @NotNull String localIdKey)

Method Summary

Modifier and Type	Method and Description
void	close()
void	localMasterIdSwitchCompleted(byte id) Notifies that the user of this QueueSwitcher has performed all necessary steps involved with switching to the provided newMasterHostId.
void	masterChangeSubscriber(@NotNull Consumer<? super Byte> masterChangeSubscriber) Notify of changes made to the control map
byte	masterHostId() Returns the current master host id.
QueueView<T,M>	queue(byte id) Returns a QueueView for the sub-queue for the provided id.
void	setMaster(byte master)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.chronicle.datagrid.internal.queue.QueueSwitcher

ofMapControlled, setMaster

Constructor Detail

MapControlledQueueSwitcher

public MapControlledQueueSwitcher(@NotNull
                                  @NotNull Asset asset,
                                  @NotNull
                                  @NotNull QueueCfg queueCfg,
                                  @NotNull
                                  @NotNull Map<Byte,QueueProxyReplica> replicas,
                                  @NotNull
                                  @NotNull MapView<CharSequence,Byte> controlMap,
                                  @NotNull
                                  @NotNull String masterIdKey,
                                  @NotNull
                                  @NotNull String localIdKey)

Method Detail

masterChangeSubscriber

public void masterChangeSubscriber(@NotNull
                                   @NotNull Consumer<? super Byte> masterChangeSubscriber)

Description copied from interface: QueueSwitcher

Notify of changes made to the control map

Specified by:

masterChangeSubscriber in interface QueueSwitcher<T,M>

Parameters:

masterChangeSubscriber - subscriber

setMaster

public void setMaster(byte master)

Specified by:

setMaster in interface QueueSwitcher<T,M>

masterHostId

public byte masterHostId()

Description copied from interface: QueueSwitcher

Returns the current master host id.

Specified by:

masterHostId in interface QueueSwitcher<T,M>

Returns:

the current master host id

localMasterIdSwitchCompleted

public void localMasterIdSwitchCompleted(byte id)

Description copied from interface: QueueSwitcher

Notifies that the user of this QueueSwitcher has performed all necessary steps involved with switching to the provided newMasterHostId.

Specified by:

localMasterIdSwitchCompleted in interface QueueSwitcher<T,M>

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

queue

public QueueView<T,M> queue(byte id)

Description copied from interface: QueueSwitcher

Returns a QueueView for the sub-queue for the provided id.

Specified by:

queue in interface QueueSwitcher<T,M>

Returns:

a QueueView for the sub-queue for the provided id