Package org.apache.activemq.artemis.core.server.cluster.impl

Class ClusterConnectionImpl.TopologyScanner

java.lang.Object

org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

org.apache.activemq.artemis.core.server.cluster.impl.ClusterConnectionImpl.TopologyScanner

All Implemented Interfaces:

Runnable, ActiveMQComponent

Enclosing class:

ClusterConnectionImpl

public final class ClusterConnectionImpl.TopologyScanner
extends ActiveMQScheduledComponent

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

executor, scheduledExecutorService

Method Summary

Modifier and Type	Method	Description
protected static boolean	compareTCs(TransportConfiguration config, TransportConfiguration otherConfig)
boolean	delay()	A delay request can succeed only if: there is no other pending delay request there is no pending execution request
boolean	isRunning()
void	resetCounter()
void	run()

Methods inherited from class org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

getInitialDelay, getPeriod, getThreadFactory, getTimeUnit, isStarted, setInitialDelay, setInitialDelayAndPeriod, setInitialDelayAndPeriod, setPeriod, setPeriod, setTimeUnit, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Method Details

isRunning

public boolean isRunning()

delay

public boolean delay()

Description copied from class: ActiveMQScheduledComponent

A delay request can succeed only if:

• there is no other pending delay request
• there is no pending execution request

When a delay request succeed it schedule a new execution to happen in ActiveMQScheduledComponent.getPeriod().

Overrides:

delay in class ActiveMQScheduledComponent

resetCounter

public void resetCounter()

run

public void run()

compareTCs

protected static boolean compareTCs(TransportConfiguration config,
 TransportConfiguration otherConfig)