com.atomikos.jms.extra

Class BatchingMessageDrivenContainer

java.lang.Object

com.atomikos.jms.extra.MessageDrivenContainer

com.atomikos.jms.extra.BatchingMessageDrivenContainer

All Implemented Interfaces:

com.atomikos.icatch.OrderedLifecycleComponent

public class BatchingMessageDrivenContainer
extends MessageDrivenContainer

LICENSED TO CUSTOMERS OF A COMMERCIAL SUBSCRIPTION ONLY! Specialized container for batching JMS messages for high performance. For maximum performance, make sure to set the "supportsTmJoin" flag to false on the connection factory as well as on any datasources you are using to process the messages.

Constructor Summary

Constructors

Constructor and Description
BatchingMessageDrivenContainer()

Method Summary

Modifier and Type	Method and Description
protected com.atomikos.jms.extra.MessageConsumerSession	createSession()
int	getBatchSize()
void	setAtomikosConnectionFactoryBean(AtomikosConnectionFactoryBean connectionFactory) Sets the connection factory to use.
void	setBatchSize(int size) The (maximum) batch size that the batch can grow towards.

Methods inherited from class com.atomikos.jms.extra.MessageDrivenContainer

close, getAtomikosConnectionFactoryBean, getDaemonThreads, getDestination, getDestinationName, getExceptionListener, getMessageListener, getMessageSelector, getNoLocal, getNotifyListenerOnClose, getPoolSize, getReceiveTimeout, getSubscriberName, getTransactionTimeout, getUnsubscribeOnClose, init, isNoLocal, setClientID, setDaemonThreads, setDestination, setDestinationName, setExceptionListener, setMessageListener, setMessageSelector, setNoLocal, setNotifyListenerOnClose, setPoolSize, setReceiveTimeout, setSubscriberName, setTransactionTimeout, setUnsubscribeOnClose, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchingMessageDrivenContainer

public BatchingMessageDrivenContainer()

Method Detail

setBatchSize

public void setBatchSize(int size)

The (maximum) batch size that the batch can grow towards. In case of exceptions, the batch size may not be reached immediately.

Parameters:

size - defaults to 50

getBatchSize

public int getBatchSize()

setAtomikosConnectionFactoryBean

public void setAtomikosConnectionFactoryBean(AtomikosConnectionFactoryBean connectionFactory)

Description copied from class: MessageDrivenContainer

Sets the connection factory to use. Required.

Overrides:

setAtomikosConnectionFactoryBean in class MessageDrivenContainer

createSession

protected com.atomikos.jms.extra.MessageConsumerSession createSession()

Overrides:

createSession in class MessageDrivenContainer