Class AbstractPool
java.lang.Object
org.apache.activemq.artemis.core.server.routing.pools.AbstractPool
- All Implemented Interfaces:
ActiveMQComponent,Pool
- Direct Known Subclasses:
ClusterPool,DiscoveryPool,StaticPool
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidaddTarget(TransportConfiguration connector, String nodeID) booleanvoidaddTargetProbe(TargetProbe probe) intintintgetReadyTarget(String nodeId) booleanbooleanisTargetReady(Target target) booleanremoveTarget(Target target) voidremoveTargetProbe(TargetProbe probe) voidsetPassword(String password) voidsetQuorumSize(int quorumSize) voidsetQuorumTimeout(int quorumTimeout) voidsetUsername(String username) voidstart()voidstop()Methods 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
-
AbstractPool
public AbstractPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod)
-
-
Method Details
-
getUsername
- Specified by:
getUsernamein interfacePool
-
setUsername
- Specified by:
setUsernamein interfacePool
-
getPassword
- Specified by:
getPasswordin interfacePool
-
setPassword
- Specified by:
setPasswordin interfacePool
-
getCheckPeriod
public int getCheckPeriod()- Specified by:
getCheckPeriodin interfacePool
-
getQuorumSize
public int getQuorumSize()- Specified by:
getQuorumSizein interfacePool
-
getQuorumTimeout
public int getQuorumTimeout()- Specified by:
getQuorumTimeoutin interfacePool
-
setQuorumTimeout
public void setQuorumTimeout(int quorumTimeout) - Specified by:
setQuorumTimeoutin interfacePool
-
setQuorumSize
public void setQuorumSize(int quorumSize) - Specified by:
setQuorumSizein interfacePool
-
getAllTargets
- Specified by:
getAllTargetsin interfacePool
-
getTargets
- Specified by:
getTargetsin interfacePool
-
getTargetProbes
- Specified by:
getTargetProbesin interfacePool
-
isStarted
public boolean isStarted()- Specified by:
isStartedin interfaceActiveMQComponent
-
getTarget
-
isTargetReady
- Specified by:
isTargetReadyin interfacePool
-
getReadyTarget
- Specified by:
getReadyTargetin interfacePool
-
addTargetProbe
- Specified by:
addTargetProbein interfacePool
-
removeTargetProbe
- Specified by:
removeTargetProbein interfacePool
-
start
- Specified by:
startin interfaceActiveMQComponent- Throws:
Exception
-
stop
- Specified by:
stopin interfaceActiveMQComponent- Throws:
Exception
-
addTarget
-
addTarget
-
removeTarget
- Specified by:
removeTargetin interfacePool
-