Package org.mule.jms.commons.internal.operation

Class JmsConsume

java.lang.Object

org.mule.jms.commons.internal.operation.JmsConsume

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable

public class JmsConsume
extends Object
implements org.mule.runtime.api.lifecycle.Disposable

Operation that allows the user to consume a single Message from a given Destination

Since:

1.0

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor	Description
JmsConsume(JmsSessionManager sessionManager, org.mule.runtime.api.scheduler.SchedulerService schedulerService)

Method Summary

Modifier and Type	Method	Description
org.mule.runtime.extension.api.runtime.operation.Result<Object,JmsAttributes>	consume(JmsConfig<?,?> config, JmsTransactionalConnection connection, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String contentType, String encoding, Long maximumWait, TimeUnit maximumWaitUnit, org.mule.runtime.extension.api.tx.OperationTransactionalAction transactionalAction)
void	consume(JmsConfig<?,?> config, JmsTransactionalConnection connection, String destination, ConsumerType consumerType, JmsAckMode ackMode, String selector, String contentType, String encoding, Long maximumWait, TimeUnit maximumWaitUnit, org.mule.runtime.extension.api.tx.OperationTransactionalAction transactionalAction, org.mule.runtime.extension.api.runtime.process.CompletionCallback<Object,JmsAttributes> completionCallback)
void	dispose()
boolean	isConnectionException(Exception e)

Methods inherited from class java.lang.Object

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

Constructor Details

JmsConsume

public JmsConsume(JmsSessionManager sessionManager,
 org.mule.runtime.api.scheduler.SchedulerService schedulerService)

Method Details

consume

public org.mule.runtime.extension.api.runtime.operation.Result<Object,JmsAttributes> consume(JmsConfig<?,?> config,
 JmsTransactionalConnection connection,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String contentType,
 String encoding,
 Long maximumWait,
 TimeUnit maximumWaitUnit,
 org.mule.runtime.extension.api.tx.OperationTransactionalAction transactionalAction)
                                                                                      throws JmsExtensionException,
org.mule.runtime.api.connection.ConnectionException

Throws:

JmsExtensionException

org.mule.runtime.api.connection.ConnectionException

consume

public void consume(JmsConfig<?,?> config,
 JmsTransactionalConnection connection,
 String destination,
 ConsumerType consumerType,
 JmsAckMode ackMode,
 String selector,
 String contentType,
 String encoding,
 Long maximumWait,
 TimeUnit maximumWaitUnit,
 org.mule.runtime.extension.api.tx.OperationTransactionalAction transactionalAction,
 org.mule.runtime.extension.api.runtime.process.CompletionCallback<Object,JmsAttributes> completionCallback)
             throws JmsExtensionException

Throws:

JmsExtensionException

isConnectionException

public boolean isConnectionException(Exception e)

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.api.lifecycle.Disposable