org.springframework.integration.store

Class AbstractBatchingMessageGroupStore

java.lang.Object

org.springframework.integration.store.AbstractBatchingMessageGroupStore

All Implemented Interfaces:

BasicMessageGroupStore

Direct Known Subclasses:

AbstractMessageGroupStore

public abstract class AbstractBatchingMessageGroupStore
extends Object
implements BasicMessageGroupStore

Since:

4.2

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
AbstractBatchingMessageGroupStore()

Method Summary

Modifier and Type	Method and Description
protected MessageGroupFactory	getMessageGroupFactory()
int	getRemoveBatchSize()
void	setMessageGroupFactory(MessageGroupFactory messageGroupFactory) Specify the MessageGroupFactory to create MessageGroup object where it is necessary.
void	setRemoveBatchSize(int removeBatchSize) Set the batch size when bulk removing messages from groups for message stores that support batch removal.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.store.BasicMessageGroupStore

addMessageToGroup, getMessageGroup, messageGroupSize, pollMessageFromGroup, removeMessageGroup

Constructor Detail

AbstractBatchingMessageGroupStore

public AbstractBatchingMessageGroupStore()

Method Detail

setRemoveBatchSize

public void setRemoveBatchSize(int removeBatchSize)

Set the batch size when bulk removing messages from groups for message stores that support batch removal. Default 100.

Parameters:

removeBatchSize - the batch size.

Since:

4.2

getRemoveBatchSize

public int getRemoveBatchSize()

setMessageGroupFactory

public void setMessageGroupFactory(MessageGroupFactory messageGroupFactory)

Specify the MessageGroupFactory to create MessageGroup object where it is necessary. Defaults to SimpleMessageGroupFactory.

Parameters:

messageGroupFactory - the MessageGroupFactory to use.

Since:

4.3

getMessageGroupFactory

protected MessageGroupFactory getMessageGroupFactory()