Class AsyncJms2ProducerFacade

java.lang.Object
org.apache.activemq.artemis.cli.commands.messages.perf.AsyncJms2ProducerFacade
public final class AsyncJms2ProducerFacade extends Object

  • Field Details

    • session

      protected final javax.jms.Session session

  • Constructor Details

    • AsyncJms2ProducerFacade

      public AsyncJms2ProducerFacade(long id, javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination destination, long maxPending, long transactionCapacity)

  • Method Details

    • getId

      public long getId()

    • getDestination

      public javax.jms.Destination getDestination()

    • trySend

      public AsyncJms2ProducerFacade.SendAttemptResult trySend(javax.jms.Message message, javax.jms.CompletionListener completionListener, Runnable availableObserver) throws javax.jms.JMSException
      Throws:
      javax.jms.JMSException

    • onSendErrored

      public void onSendErrored()

    • onSendCompleted

      public javax.jms.JMSException onSendCompleted()

    • getMessageSent

      public long getMessageSent()

    • getMessageCompleted

      public long getMessageCompleted()

    • getNotAvailable

      public long getNotAvailable()

    • requestClose

      public void requestClose()

    • requestClose

      public void requestClose(Runnable onClosed)