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

Class AsyncJms2ProducerFacade

java.lang.Object

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

public final class AsyncJms2ProducerFacade
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncJms2ProducerFacade.SendAttemptResult

Field Summary

Fields

Modifier and Type	Field	Description
protected javax.jms.Session	session

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
javax.jms.Destination	getDestination()
long	getId()
long	getMessageCompleted()
long	getMessageSent()
long	getNotAvailable()
javax.jms.JMSException	onSendCompleted()
void	onSendErrored()
void	requestClose()
void	requestClose(Runnable onClosed)
AsyncJms2ProducerFacade.SendAttemptResult	trySend(javax.jms.Message message, javax.jms.CompletionListener completionListener, Runnable availableObserver)

Methods inherited from class java.lang.Object

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

Field Detail

session

protected final javax.jms.Session session

Constructor Detail

AsyncJms2ProducerFacade

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

Method Detail

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)