public class QueueChannelSpec extends MessageChannelSpec<QueueChannelSpec,org.springframework.integration.channel.QueueChannel>
| Modifier and Type | Class and Description |
|---|---|
static class |
QueueChannelSpec.MessageStoreSpec |
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.Integer |
capacity |
protected java.util.concurrent.BlockingQueue<org.springframework.messaging.Message<?>> |
queue |
channelid, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.integration.channel.QueueChannel |
doGet() |
datatype, id, interceptor, messageConverter_this, getprotected java.util.concurrent.BlockingQueue<org.springframework.messaging.Message<?>> queue
protected java.lang.Integer capacity
protected org.springframework.integration.channel.QueueChannel doGet()
doGet in class MessageChannelSpec<QueueChannelSpec,org.springframework.integration.channel.QueueChannel>