Package org.apache.activemq.artemis.cli.commands.messages

Class Transfer

java.lang.Object

org.apache.activemq.artemis.cli.commands.ActionAbstract

org.apache.activemq.artemis.cli.commands.InputAbstract

org.apache.activemq.artemis.cli.commands.messages.Transfer

All Implemented Interfaces:

Runnable, Action

public class Transfer
extends InputAbstract

Field Summary

Fields

Modifier and Type	Field	Description
protected String	sourceAcceptor
protected String	sourcePassword
protected String	sourceURL
protected String	sourceUser
protected String	targetPassword
protected String	targetURL
protected String	targetUser

Fields inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

DEFAULT_BROKER_ACCEPTOR, DEFAULT_BROKER_URL, verbose

Constructor Summary

Constructors

Constructor	Description
Transfer()

Method Summary

Modifier and Type	Method	Description
protected javax.jms.ConnectionFactory	createConnectionFactory(String role, String protocol, String brokerURL, String user, String password, String clientID)
protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory	createCoreConnectionFactory(String brokerURL, String user, String password, String clientID)
Object	execute(ActionContext context)
int	getCommitInterval()
String	getDurableConsumer()
String	getFilter()
int	getMessageCount()
int	getReceiveTimeout()
String	getSharedDurableSubscription()
String	getSharedSubscription()
String	getSourceAcceptor()
String	getSourceClientID()
String	getSourcePassword()
String	getSourceProtocol()
String	getSourceQueue()
String	getSourceTopic()
String	getSourceURL()
String	getSourceUser()
String	getTargetPassword()
String	getTargetProtocol()
String	getTargetQueue()
String	getTargetTopic()
String	getTargetURL()
String	getTargetUser()
boolean	isCopy()
boolean	isNoLocal()
Transfer	setCommitInterval(int commitInterval)
Transfer	setCopy(boolean copy)
Transfer	setDurableConsumer(String durableConsumer)
Transfer	setFilter(String filter)
Transfer	setMessageCount(int messageCount)
Transfer	setNoLocal(boolean noLocal)
Transfer	setReceiveTimeout(int receiveTimeout)
Transfer	setSharedDurableSubscription(String sharedDurableSubscription)
Transfer	setSharedSubscription(String sharedSubscription)
Transfer	setSourceAcceptor(String sourceAcceptor)
Transfer	setSourceClientID(String sourceClientID)
Transfer	setSourcePassword(String sourcePassword)
Transfer	setSourceProtocol(String sourceProtocol)
Transfer	setSourceQueue(String sourceQueue)
Transfer	setSourceTopic(String sourceTopic)
Transfer	setSourceURL(String sourceURL)
Transfer	setSourceUser(String sourceUser)
Transfer	setTargetPassword(String targetPassword)
Transfer	setTargetProtocol(String targetProtocol)
Transfer	setTargetQueue(String targetQueue)
Transfer	setTargetTopic(String targetTopic)
Transfer	setTargetURL(String targetURL)
Transfer	setTargetUser(String targetUser)

Methods inherited from class org.apache.activemq.artemis.cli.commands.InputAbstract

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

Methods inherited from class org.apache.activemq.artemis.cli.commands.ActionAbstract

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

Methods inherited from class java.lang.Object

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

Field Detail

sourceURL

protected String sourceURL

sourceAcceptor

protected String sourceAcceptor

sourceUser

protected String sourceUser

sourcePassword

protected String sourcePassword

targetURL

protected String targetURL

targetUser

protected String targetUser

targetPassword

protected String targetPassword

Constructor Detail

Transfer

public Transfer()

Method Detail

getSourceURL

public String getSourceURL()

setSourceURL

public Transfer setSourceURL(String sourceURL)

getSourceAcceptor

public String getSourceAcceptor()

setSourceAcceptor

public Transfer setSourceAcceptor(String sourceAcceptor)

getSourceUser

public String getSourceUser()

setSourceUser

public Transfer setSourceUser(String sourceUser)

getSourcePassword

public String getSourcePassword()

setSourcePassword

public Transfer setSourcePassword(String sourcePassword)

getTargetURL

public String getTargetURL()

setTargetURL

public Transfer setTargetURL(String targetURL)

getTargetUser

public String getTargetUser()

setTargetUser

public Transfer setTargetUser(String targetUser)

getTargetPassword

public String getTargetPassword()

setTargetPassword

public Transfer setTargetPassword(String targetPassword)

getReceiveTimeout

public int getReceiveTimeout()

setReceiveTimeout

public Transfer setReceiveTimeout(int receiveTimeout)

getSourceClientID

public String getSourceClientID()

setSourceClientID

public Transfer setSourceClientID(String sourceClientID)

getSourceProtocol

public String getSourceProtocol()

setSourceProtocol

public Transfer setSourceProtocol(String sourceProtocol)

getSourceQueue

public String getSourceQueue()

setSourceQueue

public Transfer setSourceQueue(String sourceQueue)

getSharedDurableSubscription

public String getSharedDurableSubscription()

setSharedDurableSubscription

public Transfer setSharedDurableSubscription(String sharedDurableSubscription)

getSharedSubscription

public String getSharedSubscription()

setSharedSubscription

public Transfer setSharedSubscription(String sharedSubscription)

getDurableConsumer

public String getDurableConsumer()

setDurableConsumer

public Transfer setDurableConsumer(String durableConsumer)

isNoLocal

public boolean isNoLocal()

setNoLocal

public Transfer setNoLocal(boolean noLocal)

getSourceTopic

public String getSourceTopic()

setSourceTopic

public Transfer setSourceTopic(String sourceTopic)

getFilter

public String getFilter()

setFilter

public Transfer setFilter(String filter)

getTargetProtocol

public String getTargetProtocol()

setTargetProtocol

public Transfer setTargetProtocol(String targetProtocol)

getCommitInterval

public int getCommitInterval()

setCommitInterval

public Transfer setCommitInterval(int commitInterval)

isCopy

public boolean isCopy()

setCopy

public Transfer setCopy(boolean copy)

getTargetQueue

public String getTargetQueue()

setTargetQueue

public Transfer setTargetQueue(String targetQueue)

getTargetTopic

public String getTargetTopic()

setTargetTopic

public Transfer setTargetTopic(String targetTopic)

getMessageCount

public int getMessageCount()

setMessageCount

public Transfer setMessageCount(int messageCount)

execute

public Object execute(ActionContext context)
               throws Exception

Specified by:

execute in interface Action

Overrides:

execute in class InputAbstract

Throws:

Exception

createConnectionFactory

protected javax.jms.ConnectionFactory createConnectionFactory(String role,
                                                              String protocol,
                                                              String brokerURL,
                                                              String user,
                                                              String password,
                                                              String clientID)
                                                       throws Exception

Throws:

Exception

createCoreConnectionFactory

protected org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory createCoreConnectionFactory(String brokerURL,
                                                                                                       String user,
                                                                                                       String password,
                                                                                                       String clientID)