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 Details

    • 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 Details

    • Transfer

      public Transfer()

  • Method Details

    • 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 ConnectionFactoryClosable createConnectionFactory(String role, String protocol, String brokerURL, String user, String password, String clientID) throws Exception
      Throws:
      Exception

    • createCoreConnectionFactory

      protected ActiveMQConnectionFactory createCoreConnectionFactory(String brokerURL, String user, String password, String clientID)