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:

Action

@Command(name="transfer",
         description="Moves Messages from one destination towards another destination")
public class Transfer
extends InputAbstract

Field Summary

Fields

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

checkOptions, getActionContext, getBrokerConfiguration, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, getBrokerURLInstance, isVerbose, setHomeValues

Methods inherited from class java.lang.Object

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

Field Detail

sourceURL

protected java.lang.String sourceURL

sourceAcceptor

protected java.lang.String sourceAcceptor

sourceUser

protected java.lang.String sourceUser

sourcePassword

protected java.lang.String sourcePassword

targetURL

protected java.lang.String targetURL

targetUser

protected java.lang.String targetUser

targetPassword

protected java.lang.String targetPassword

Constructor Detail

Transfer

public Transfer()

Method Detail

getSourceURL

public java.lang.String getSourceURL()

setSourceURL

public Transfer setSourceURL(java.lang.String sourceURL)

getSourceAcceptor

public java.lang.String getSourceAcceptor()

setSourceAcceptor

public Transfer setSourceAcceptor(java.lang.String sourceAcceptor)

getSourceUser

public java.lang.String getSourceUser()

setSourceUser

public Transfer setSourceUser(java.lang.String sourceUser)

getSourcePassword

public java.lang.String getSourcePassword()

setSourcePassword

public Transfer setSourcePassword(java.lang.String sourcePassword)

getTargetURL

public java.lang.String getTargetURL()

setTargetURL

public Transfer setTargetURL(java.lang.String targetURL)

getTargetUser

public java.lang.String getTargetUser()

setTargetUser

public Transfer setTargetUser(java.lang.String targetUser)

getTargetPassword

public java.lang.String getTargetPassword()

setTargetPassword

public Transfer setTargetPassword(java.lang.String targetPassword)

getReceiveTimeout

public int getReceiveTimeout()

setReceiveTimeout

public Transfer setReceiveTimeout(int receiveTimeout)

getSourceClientID

public java.lang.String getSourceClientID()

setSourceClientID

public Transfer setSourceClientID(java.lang.String sourceClientID)

getSourceProtocol

public java.lang.String getSourceProtocol()

setSourceProtocol

public Transfer setSourceProtocol(java.lang.String sourceProtocol)

getSourceQueue

public java.lang.String getSourceQueue()

setSourceQueue

public Transfer setSourceQueue(java.lang.String sourceQueue)

getSharedDurableSubscription

public java.lang.String getSharedDurableSubscription()

setSharedDurableSubscription

public Transfer setSharedDurableSubscription(java.lang.String sharedDurableSubscription)

getSharedSubscription

public java.lang.String getSharedSubscription()

setSharedSubscription

public Transfer setSharedSubscription(java.lang.String sharedSubscription)

getDurableConsumer

public java.lang.String getDurableConsumer()

setDurableConsumer

public Transfer setDurableConsumer(java.lang.String durableConsumer)

isNoLocal

public boolean isNoLocal()

setNoLocal

public Transfer setNoLocal(boolean noLocal)

getSourceTopic

public java.lang.String getSourceTopic()

setSourceTopic

public Transfer setSourceTopic(java.lang.String sourceTopic)

getFilter

public java.lang.String getFilter()

setFilter

public Transfer setFilter(java.lang.String filter)

getTargetProtocol

public java.lang.String getTargetProtocol()

setTargetProtocol

public Transfer setTargetProtocol(java.lang.String targetProtocol)

getCommitInterval

public int getCommitInterval()

setCommitInterval

public Transfer setCommitInterval(int commitInterval)

isCopy

public boolean isCopy()

setCopy

public Transfer setCopy(boolean copy)

getTargetQueue

public java.lang.String getTargetQueue()

setTargetQueue

public Transfer setTargetQueue(java.lang.String targetQueue)

getTargetTopic

public java.lang.String getTargetTopic()

setTargetTopic

public Transfer setTargetTopic(java.lang.String targetTopic)

getMessageCount

public int getMessageCount()

setMessageCount

public Transfer setMessageCount(int messageCount)

execute

public java.lang.Object execute(ActionContext context)
                         throws java.lang.Exception

Specified by:

execute in interface Action

Overrides:

execute in class InputAbstract

Throws:

java.lang.Exception

createConnectionFactory

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

Throws:

java.lang.Exception

createCoreConnectionFactory

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