Package com.swiftmq.impl.jms.standard.v630

Class AsyncMessageProcessor

java.lang.Object

com.swiftmq.swiftlet.queue.MessageProcessor

com.swiftmq.impl.jms.standard.v630.AsyncMessageProcessor

All Implemented Interfaces:

com.swiftmq.swiftlet.threadpool.AsyncTask, Runnable

public class AsyncMessageProcessor
extends com.swiftmq.swiftlet.queue.MessageProcessor

Constructor Summary

Constructors

Constructor	Description
AsyncMessageProcessor(Session session, SessionContext ctx, Consumer consumer, int consumerCacheSize, int recoveryEpoche)

Method Summary

Modifier and Type	Method	Description
int	getConsumerCacheSize()
String	getDescription()
String	getDispatchToken()
boolean	isValid()
void	processException(Exception exception)
void	processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
void	processMessages(int numberMessages)
void	register()
void	reset()
void	run()
void	setConsumerCacheSize(int consumerCacheSize)
void	stop()

Methods inherited from class com.swiftmq.swiftlet.queue.MessageProcessor

createBulkBuffer, getBulkBuffer, getCurrentBulkSize, getMaxBulkSize, getReceiverId, getRegistrationId, getRegistrationTime, getSelector, getTimeout, getTransactionId, getViewId, isAutoCommit, isBulkMode, setAutoCommit, setBulkMode, setCurrentBulkSize, setReceiverId, setRegistrationId, setRegistrationTime, setTransactionId, setViewId

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncMessageProcessor

public AsyncMessageProcessor(Session session,
 SessionContext ctx,
 Consumer consumer,
 int consumerCacheSize,
 int recoveryEpoche)

Method Details

getConsumerCacheSize

public int getConsumerCacheSize()

setConsumerCacheSize

public void setConsumerCacheSize(int consumerCacheSize)

isValid

public boolean isValid()

stop

public void stop()

Specified by:

stop in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

stop in class com.swiftmq.swiftlet.queue.MessageProcessor

reset

public void reset()

Overrides:

reset in class com.swiftmq.swiftlet.queue.MessageProcessor

processMessages

public void processMessages(int numberMessages)

Overrides:

processMessages in class com.swiftmq.swiftlet.queue.MessageProcessor

processMessage

public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)

Specified by:

processMessage in class com.swiftmq.swiftlet.queue.MessageProcessor

processException

public void processException(Exception exception)

Specified by:

processException in class com.swiftmq.swiftlet.queue.MessageProcessor

register

public void register()

run

public void run()

Specified by:

run in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Specified by:

run in interface Runnable

Overrides:

run in class com.swiftmq.swiftlet.queue.MessageProcessor

getDescription

public String getDescription()

Specified by:

getDescription in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDescription in class com.swiftmq.swiftlet.queue.MessageProcessor

getDispatchToken

public String getDispatchToken()

Specified by:

getDispatchToken in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDispatchToken in class com.swiftmq.swiftlet.queue.MessageProcessor