Package org.apache.activemq.artemis.core.server.routing.targets

Class TargetMonitor

java.lang.Object

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

org.apache.activemq.artemis.core.server.routing.targets.TargetMonitor

All Implemented Interfaces:

Runnable, ActiveMQComponent, TargetListener

public class TargetMonitor
extends ActiveMQScheduledComponent
implements TargetListener

Field Summary

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

executor, scheduledExecutorService

Constructor Summary

Constructors

Constructor	Description
TargetMonitor(ScheduledExecutorService scheduledExecutorService, int checkPeriod, Target target, List<TargetProbe> targetProbes)

Method Summary

Modifier and Type	Method	Description
Target	getTarget()
boolean	isTargetReady()
void	run()
void	start()
void	stop()
void	targetConnected()
void	targetDisconnected()
String	toString()

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

delay, getInitialDelay, getPeriod, getThreadFactory, getTimeUnit, isStarted, setInitialDelay, setInitialDelayAndPeriod, setInitialDelayAndPeriod, setPeriod, setPeriod, setTimeUnit

Methods inherited from class java.lang.Object

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

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

asyncStop

Constructor Details

TargetMonitor

public TargetMonitor(ScheduledExecutorService scheduledExecutorService,
 int checkPeriod,
 Target target,
 List<TargetProbe> targetProbes)

Method Details

getTarget

public Target getTarget()

isTargetReady

public boolean isTargetReady()

start

public void start()

Specified by:

start in interface ActiveMQComponent

Overrides:

start in class ActiveMQScheduledComponent

stop

public void stop()

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class ActiveMQScheduledComponent

run

public void run()

Specified by:

run in interface Runnable

targetConnected

public void targetConnected()

Specified by:

targetConnected in interface TargetListener

targetDisconnected

public void targetDisconnected()

Specified by:

targetDisconnected in interface TargetListener

toString

public String toString()

Overrides:

toString in class Object