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

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

public abstract class AbstractPool
extends Object
implements Pool

Constructor Summary

Constructors

Constructor	Description
AbstractPool(TargetFactory targetFactory, ScheduledExecutorService scheduledExecutor, int checkPeriod)

Method Summary

Modifier and Type	Method	Description
protected void	addTarget(TransportConfiguration connector, String nodeID)
boolean	addTarget(Target target)
void	addTargetProbe(TargetProbe probe)
List<Target>	getAllTargets()
int	getCheckPeriod()
String	getPassword()
int	getQuorumSize()
int	getQuorumTimeout()
Target	getReadyTarget(String nodeId)
Target	getTarget(String nodeId)
List<TargetProbe>	getTargetProbes()
List<Target>	getTargets()
String	getUsername()
boolean	isStarted()
boolean	isTargetReady(Target target)
boolean	removeTarget(Target target)
void	removeTargetProbe(TargetProbe probe)
void	setPassword(String password)
void	setQuorumSize(int quorumSize)
void	setQuorumTimeout(int quorumTimeout)
void	setUsername(String username)
void	start()
void	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

Constructor Details

AbstractPool

public AbstractPool(TargetFactory targetFactory,
 ScheduledExecutorService scheduledExecutor,
 int checkPeriod)

Method Details

getUsername

public String getUsername()

Specified by:

getUsername in interface Pool

setUsername

public void setUsername(String username)

Specified by:

setUsername in interface Pool

getPassword

public String getPassword()

Specified by:

getPassword in interface Pool

setPassword

public void setPassword(String password)

Specified by:

setPassword in interface Pool

getCheckPeriod

public int getCheckPeriod()

Specified by:

getCheckPeriod in interface Pool

getQuorumSize

public int getQuorumSize()

Specified by:

getQuorumSize in interface Pool

getQuorumTimeout

public int getQuorumTimeout()

Specified by:

getQuorumTimeout in interface Pool

setQuorumTimeout

public void setQuorumTimeout(int quorumTimeout)

Specified by:

setQuorumTimeout in interface Pool

setQuorumSize

public void setQuorumSize(int quorumSize)

Specified by:

setQuorumSize in interface Pool

getAllTargets

public List<Target> getAllTargets()

Specified by:

getAllTargets in interface Pool

getTargets

public List<Target> getTargets()

Specified by:

getTargets in interface Pool

getTargetProbes

public List<TargetProbe> getTargetProbes()

Specified by:

getTargetProbes in interface Pool

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getTarget

public Target getTarget(String nodeId)

Specified by:

getTarget in interface Pool

isTargetReady

public boolean isTargetReady(Target target)

Specified by:

isTargetReady in interface Pool

getReadyTarget

public Target getReadyTarget(String nodeId)

Specified by:

getReadyTarget in interface Pool

addTargetProbe

public void addTargetProbe(TargetProbe probe)

Specified by:

addTargetProbe in interface Pool

removeTargetProbe

public void removeTargetProbe(TargetProbe probe)

Specified by:

removeTargetProbe in interface Pool

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

addTarget

protected void addTarget(TransportConfiguration connector,
 String nodeID)

addTarget

public boolean addTarget(Target target)

Specified by:

addTarget in interface Pool

removeTarget

public boolean removeTarget(Target target)

Specified by:

removeTarget in interface Pool