public class QueueChannelSpec extends MessageChannelSpec<QueueChannelSpec,QueueChannel>
| Modifier and Type | Class and Description |
|---|---|
static class |
QueueChannelSpec.MessageStoreSpec
The
ChannelMessageStore-specific QueueChannelSpec extension. |
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.Integer |
capacity |
protected java.util.Queue<org.springframework.messaging.Message<?>> |
queue |
channelPARSER, target| Modifier | Constructor and Description |
|---|---|
protected |
QueueChannelSpec() |
protected |
QueueChannelSpec(java.lang.Integer capacity) |
protected |
QueueChannelSpec(java.util.Queue<org.springframework.messaging.Message<?>> queue) |
| Modifier and Type | Method and Description |
|---|---|
protected QueueChannel |
doGet() |
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected java.util.Queue<org.springframework.messaging.Message<?>> queue
protected java.lang.Integer capacity
protected QueueChannelSpec()
protected QueueChannelSpec(java.util.Queue<org.springframework.messaging.Message<?>> queue)
protected QueueChannelSpec(java.lang.Integer capacity)
protected QueueChannel doGet()
doGet in class MessageChannelSpec<QueueChannelSpec,QueueChannel>