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

Class PerfClientCommand

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.BasicConnectionAbstract
org.apache.activemq.artemis.cli.commands.messages.ConnectionAbstract
org.apache.activemq.artemis.cli.commands.messages.perf.PerfCommand
org.apache.activemq.artemis.cli.commands.messages.perf.PerfClientCommand
All Implemented Interfaces:
Runnable, Action
public class PerfClientCommand extends PerfCommand

  • Field Details

    • transaction

      protected boolean transaction

    • sharedSubscription

      protected int sharedSubscription

    • durableSubscription

      protected boolean durableSubscription

    • consumerConnections

      protected int consumerConnections

    • consumersPerDestination

      protected int consumersPerDestination

    • persistent

      protected boolean persistent

    • messageSize

      protected int messageSize

    • rate

      protected Long rate

    • ttl

      protected long ttl

    • msgGroupID

      protected String msgGroupID

    • sharedConnections

      protected boolean sharedConnections

    • producersPerDestination

      protected int producersPerDestination

    • threads

      protected int threads

    • maxPending

      protected long maxPending

    • consumerUrl

      protected String consumerUrl

    • consumerProtocol

      protected ConnectionProtocol consumerProtocol

    • enableMessageID

      protected boolean enableMessageID

    • enableTimestamp

      protected boolean enableTimestamp

  • Constructor Details

    • PerfClientCommand

      public PerfClientCommand()

  • Method Details

    • onExecuteBenchmark

      protected void onExecuteBenchmark(javax.jms.ConnectionFactory producerConnectionFactory, javax.jms.Destination[] jmsDestinations, ActionContext context) throws Exception
      Specified by:
      onExecuteBenchmark in class PerfCommand
      Throws:
      Exception

    • onInterruptBenchmark

      protected void onInterruptBenchmark()
      Specified by:
      onInterruptBenchmark in class PerfCommand

    • execute

      public Object execute(ActionContext context) throws Exception
      Specified by:
      execute in interface Action
      Overrides:
      execute in class PerfCommand
      Throws:
      Exception

    • isTransaction

      public boolean isTransaction()

    • setTransaction

      public PerfClientCommand setTransaction(boolean transaction)

    • getSharedSubscription

      public int getSharedSubscription()

    • setSharedSubscription

      public PerfClientCommand setSharedSubscription(int sharedSubscription)

    • isDurableSubscription

      public boolean isDurableSubscription()

    • setDurableSubscription

      public PerfClientCommand setDurableSubscription(boolean durableSubscription)

    • getConsumerConnections

      public int getConsumerConnections()

    • setConsumerConnections

      public PerfClientCommand setConsumerConnections(int consumerConnections)

    • getConsumersPerDestination

      public int getConsumersPerDestination()

    • setConsumersPerDestination

      public PerfClientCommand setConsumersPerDestination(int consumersPerDestination)

    • isPersistent

      public boolean isPersistent()

    • setPersistent

      public PerfClientCommand setPersistent(boolean persistent)

    • getMessageSize

      public int getMessageSize()

    • setMessageSize

      public PerfClientCommand setMessageSize(int messageSize)

    • getRate

      public Long getRate()

    • setRate

      public PerfClientCommand setRate(Long rate)

    • getTtl

      public long getTtl()

    • setTtl

      public PerfClientCommand setTtl(long ttl)

    • getMsgGroupID

      public String getMsgGroupID()

    • setMsgGroupID

      public PerfClientCommand setMsgGroupID(String msgGroupID)

    • isSharedConnections

      public boolean isSharedConnections()

    • setSharedConnections

      public PerfClientCommand setSharedConnections(boolean sharedConnections)

    • getProducersPerDestination

      public int getProducersPerDestination()

    • setProducersPerDestination

      public PerfClientCommand setProducersPerDestination(int producersPerDestination)

    • getThreads

      public int getThreads()

    • setThreads

      public PerfClientCommand setThreads(int threads)

    • getMaxPending

      public long getMaxPending()

    • setMaxPending

      public PerfClientCommand setMaxPending(long maxPending)

    • getConsumerUrl

      public String getConsumerUrl()

    • setConsumerUrl

      public PerfClientCommand setConsumerUrl(String consumerUrl)

    • getConsumerProtocol

      public String getConsumerProtocol()

    • setConsumerProtocol

      public PerfClientCommand setConsumerProtocol(String consumerProtocol)

    • isEnableMessageID

      public boolean isEnableMessageID()

    • setEnableMessageID

      public PerfClientCommand setEnableMessageID(boolean enableMessageID)

    • isEnableTimestamp

      public boolean isEnableTimestamp()

    • setEnableTimestamp

      public PerfClientCommand setEnableTimestamp(boolean enableTimestamp)

    • getProducerBenchmark

      public BenchmarkService getProducerBenchmark()

    • setProducerBenchmark

      public PerfClientCommand setProducerBenchmark(BenchmarkService producerBenchmark)