public static class QueueChannelSpec.MessageStoreSpec extends QueueChannelSpec
ChannelMessageStore
-specific QueueChannelSpec
extension.QueueChannelSpec.MessageStoreSpec
capacity, queue
channel
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Modifier | Constructor and Description |
---|---|
protected |
MessageStoreSpec(ChannelMessageStore messageGroupStore,
Object groupId) |
Modifier and Type | Method and Description |
---|---|
QueueChannelSpec.MessageStoreSpec |
capacity(Integer capacityToSet) |
protected QueueChannel |
doGet() |
protected QueueChannelSpec.MessageStoreSpec |
id(String id)
Configure the component identifier.
|
QueueChannelSpec.MessageStoreSpec |
storeLock(Lock storeLockToSet) |
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
protected MessageStoreSpec(ChannelMessageStore messageGroupStore, Object groupId)
protected QueueChannelSpec.MessageStoreSpec id(String id)
IntegrationComponentSpec
beanName
to register the
bean in the application context for this component.id
in class IntegrationComponentSpec<QueueChannelSpec,QueueChannel>
id
- the id.public QueueChannelSpec.MessageStoreSpec capacity(Integer capacityToSet)
public QueueChannelSpec.MessageStoreSpec storeLock(Lock storeLockToSet)
protected QueueChannel doGet()
doGet
in class QueueChannelSpec