Class DiscoveryPool
java.lang.Object
org.apache.activemq.artemis.core.server.routing.pools.AbstractPool
org.apache.activemq.artemis.core.server.routing.pools.DiscoveryPool
- All Implemented Interfaces:
ActiveMQComponent,DiscoveryService.Listener,Pool
-
Constructor Summary
ConstructorsConstructorDescriptionDiscoveryPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod, DiscoveryService discoveryService) -
Method Summary
Modifier and TypeMethodDescriptionvoidentryAdded(DiscoveryService.Entry entry) voidvoidentryUpdated(DiscoveryService.Entry oldEntry, DiscoveryService.Entry newEntry) voidstart()voidstop()Methods inherited from class org.apache.activemq.artemis.core.server.routing.pools.AbstractPool
addTarget, addTarget, addTargetProbe, getAllTargets, getCheckPeriod, getPassword, getQuorumSize, getQuorumTimeout, getReadyTarget, getTarget, getTargetProbes, getTargets, getUsername, isStarted, isTargetReady, removeTarget, removeTargetProbe, setPassword, setQuorumSize, setQuorumTimeout, setUsernameMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent
asyncStop
-
Constructor Details
-
DiscoveryPool
public DiscoveryPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod, DiscoveryService discoveryService)
-
-
Method Details
-
start
- Specified by:
startin interfaceActiveMQComponent- Overrides:
startin classAbstractPool- Throws:
Exception
-
stop
- Specified by:
stopin interfaceActiveMQComponent- Overrides:
stopin classAbstractPool- Throws:
Exception
-
entryAdded
- Specified by:
entryAddedin interfaceDiscoveryService.Listener
-
entryRemoved
- Specified by:
entryRemovedin interfaceDiscoveryService.Listener
-
entryUpdated
- Specified by:
entryUpdatedin interfaceDiscoveryService.Listener
-