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
-
Method Summary
Modifier and TypeMethodDescriptionprotected MessageGroupFactory
int
void
setMessageGroupFactory
(MessageGroupFactory messageGroupFactory) Specify theMessageGroupFactory
to createMessageGroup
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 Details
-
AbstractBatchingMessageGroupStore
public AbstractBatchingMessageGroupStore()
-
-
Method Details
-
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
Specify theMessageGroupFactory
to createMessageGroup
object where it is necessary. Defaults toSimpleMessageGroupFactory
.- Parameters:
messageGroupFactory
- theMessageGroupFactory
to use.- Since:
- 4.3
-
getMessageGroupFactory
-