Class ConnectionAbstract
java.lang.Object
org.apache.activemq.artemis.cli.commands.ActionAbstract
org.apache.activemq.artemis.cli.commands.InputAbstract
org.apache.activemq.artemis.cli.commands.messages.ConnectionConfigurationAbtract
org.apache.activemq.artemis.cli.commands.messages.ConnectionAbstract
- Direct Known Subclasses:
AddressAbstract,CheckAbstract,ClusterCheck,Connect,DeleteQueue,DestAbstract,Disconnect,PerfCommand,PurgeQueue,QueueAbstract,StatQueue,UserAction
-
Field Summary
FieldsFields inherited from class org.apache.activemq.artemis.cli.commands.messages.ConnectionConfigurationAbtract
acceptor, brokerURL, CONNECTION_INFORMATION, password, silent, userFields inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract
DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ConnectionFactoryClosableprotected ConnectionFactoryClosablecreateConnectionFactory(String brokerURL, String user, String password, String clientID, ConnectionProtocol protocol) protected ActiveMQConnectionFactoryprotected ActiveMQConnectionFactorycreateCoreConnectionFactory(String brokerURL, String user, String password, String clientID) protected voidperformCoreManagement(String uri, String user, String password, ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed) protected voidperformCoreManagement(ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed) setClientID(String clientID) voidsetProtocol(String protocol) voidsetProtocol(ConnectionProtocol protocol) protected voidtryConnect(String brokerURL, String user, String password, javax.jms.ConnectionFactory cf) Methods inherited from class org.apache.activemq.artemis.cli.commands.messages.ConnectionConfigurationAbtract
execute, getAcceptor, getBrokerURL, getPassword, getUser, inputBrokerURL, inputPassword, inputUser, recoverConnectionInformation, saveConnectionInfo, setAcceptor, setBrokerURL, setPassword, setUserMethods inherited from class org.apache.activemq.artemis.cli.commands.InputAbstract
enableInput, input, input, inputBoolean, inputInteger, inputPassword, isSilentInput, setSilentInputMethods inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract
done, getActionContext, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, run, setHomeValues
-
Field Details
-
clientID
-
protocol
-
-
Constructor Details
-
ConnectionAbstract
public ConnectionAbstract()
-
-
Method Details
-
getClientID
-
setClientID
-
getProtocol
-
setProtocol
-
setProtocol
-
createConnectionFactory
- Throws:
Exception
-
createConnectionFactory
protected ConnectionFactoryClosable createConnectionFactory(String brokerURL, String user, String password, String clientID, ConnectionProtocol protocol) throws Exception - Throws:
Exception
-
createCoreConnectionFactory
-
createCoreConnectionFactory
protected ActiveMQConnectionFactory createCoreConnectionFactory(String brokerURL, String user, String password, String clientID) -
tryConnect
protected void tryConnect(String brokerURL, String user, String password, javax.jms.ConnectionFactory cf) throws javax.jms.JMSException - Throws:
javax.jms.JMSException
-
performCoreManagement
protected void performCoreManagement(ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed) throws Exception - Throws:
Exception
-
performCoreManagement
protected void performCoreManagement(String uri, String user, String password, ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed) throws Exception - Throws:
Exception
-