public abstract class AbstractAmqCommand extends AbstractCommand
COMMAND_OPTION_DELIMETER, context
Constructor and Description |
---|
AbstractAmqCommand() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeAllConnections()
Close all created connections.
|
protected javax.jms.Connection |
createConnection()
Establishes a connection to the remote broker specified by the broker
url.
|
protected javax.jms.Connection |
createConnection(java.lang.String username,
java.lang.String password)
Establishes a connection to the remote broker specified by the broker
url.
|
protected java.net.URI |
getBrokerUrl()
Get the current broker url.
|
protected void |
handleOption(java.lang.String token,
java.util.List tokens)
Handle the --amqurl option.
|
protected void |
setBrokerUrl(java.lang.String address)
Set the broker url.
|
protected void |
setBrokerUrl(java.net.URI brokerUrl)
Set the broker url.
|
execute, parseOptions, printHelp, runTask, setCommandContext
public AbstractAmqCommand()
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Connection createConnection(java.lang.String username, java.lang.String password) throws javax.jms.JMSException
username
- - username for the connectionpassword
- - password for the connectionjavax.jms.JMSException
protected void closeAllConnections()
protected void handleOption(java.lang.String token, java.util.List tokens) throws java.lang.Exception
handleOption
in class AbstractCommand
token
- - current optiontokens
- - succeeding list of argumentsjava.lang.Exception
protected void setBrokerUrl(java.net.URI brokerUrl)
brokerUrl
- - new broker urlprotected void setBrokerUrl(java.lang.String address) throws java.net.URISyntaxException
address
- - address of the new broker urljava.net.URISyntaxException
protected java.net.URI getBrokerUrl()
Copyright © 2005-2012. All Rights Reserved.