public class QueueMessageChannel extends AbstractMessageChannel implements PollableChannel
AbstractMessageChannel.ChannelInterceptorChain
logger
INDEFINITE_TIMEOUT
コンストラクターと説明 |
---|
QueueMessageChannel(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, StringSE queueUrl) |
修飾子と型 | メソッドと説明 |
---|---|
Message<StringSE> | receive() |
Message<StringSE> | receive(long timeout) |
protected boolean | sendInternal(Message<?> message, long timeout) |
addInterceptor, addInterceptor, getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setInterceptors, setLogger, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
send, send
public QueueMessageChannel(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, StringSE queueUrl)
protected boolean sendInternal(Message<?> message, long timeout)
AbstractMessageChannel
の sendInternal
public Message<StringSE> receive()
PollableChannel
の receive
public Message<StringSE> receive(long timeout)
PollableChannel
の receive
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.