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

All Implemented Interfaces:

Runnable, Action

Direct Known Subclasses:

AddressAbstract, CheckAbstract, ClusterCheck, Connect, DeleteQueue, DestAbstract, Disconnect, PerfCommand, PurgeQueue, QueueAbstract, StatQueue, UserAction

public class ConnectionAbstract
extends ConnectionConfigurationAbtract

Field Summary

Fields

Modifier and Type	Field	Description
protected String	clientID
protected ConnectionProtocol	protocol

Fields inherited from class ConnectionConfigurationAbtract

acceptor, brokerURL, CONNECTION_INFORMATION, password, silent, user

Fields inherited from class ActionAbstract

DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
ConnectionAbstract()

Method Summary

Modifier and Type	Method	Description
protected ConnectionFactoryClosable	createConnectionFactory()
protected ConnectionFactoryClosable	createConnectionFactory(String brokerURL, String user, String password, String clientID, ConnectionProtocol protocol)
protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory	createCoreConnectionFactory()
protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory	createCoreConnectionFactory(String brokerURL, String user, String password, String clientID)
String	getClientID()
ConnectionProtocol	getProtocol()
protected void	performCoreManagement(String uri, String user, String password, ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed)
protected void	performCoreManagement(ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed)
ConnectionAbstract	setClientID(String clientID)
void	setProtocol(String protocol)
void	setProtocol(ConnectionProtocol protocol)
protected void	tryConnect(String brokerURL, String user, String password, javax.jms.ConnectionFactory cf)

Methods inherited from class ConnectionConfigurationAbtract

execute, getAcceptor, getBrokerURL, getPassword, getUser, inputBrokerURL, inputPassword, inputUser, recoverConnectionInformation, saveConnectionInfo, setAcceptor, setBrokerURL, setPassword, setUser

Methods inherited from class InputAbstract

enableInput, input, input, inputBoolean, inputInteger, inputPassword, isSilentInput, setSilentInput

Methods inherited from class ActionAbstract

done, getActionContext, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, run, setHomeValues

Methods inherited from class Object

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

Field Details

clientID

protected String clientID

protocol

protected ConnectionProtocol protocol

Constructor Details

ConnectionAbstract

public ConnectionAbstract()

Method Details

getClientID

public String getClientID()

setClientID

public ConnectionAbstract setClientID(String clientID)

getProtocol

public ConnectionProtocol getProtocol()

setProtocol

public void setProtocol(ConnectionProtocol protocol)

setProtocol

public void setProtocol(String protocol)

createConnectionFactory

protected ConnectionFactoryClosable createConnectionFactory()
                                                     throws Exception

Throws:

Exception

createConnectionFactory

protected ConnectionFactoryClosable createConnectionFactory(String brokerURL,
 String user,
 String password,
 String clientID,
 ConnectionProtocol protocol)
                                                     throws Exception

Throws:

Exception

createCoreConnectionFactory

protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory createCoreConnectionFactory()

createCoreConnectionFactory

protected org.apache.activemq.artemis.jms.client.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