io.awspring.cloud.messaging.core

Class QueueMessageChannel

java.lang.Object

org.springframework.messaging.support.AbstractMessageChannel

io.awspring.cloud.messaging.core.QueueMessageChannel

All Implemented Interfaces:

Aware, BeanNameAware, MessageChannel, PollableChannel, InterceptableChannel

public class QueueMessageChannel
extends AbstractMessageChannel
implements PollableChannel

Since:

1.0

Author:

Agim Emruli, Alain Sahli

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.messaging.support.AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorChain

Field Summary

Fields inherited from class org.springframework.messaging.support.AbstractMessageChannel

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
QueueMessageChannel(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, String queueUrl)

Method Summary

Modifier and Type	Method and Description
Message<String>	receive()
Message<String>	receive(long timeout)
protected boolean	sendInternal(Message<?> message, long timeout)

Methods inherited from class org.springframework.messaging.support.AbstractMessageChannel

addInterceptor, addInterceptor, getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setInterceptors, setLogger, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.messaging.MessageChannel

send, send

Constructor Detail

QueueMessageChannel

public QueueMessageChannel(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                           String queueUrl)

Method Detail

sendInternal

protected boolean sendInternal(Message<?> message,
                               long timeout)

Specified by:

sendInternal in class AbstractMessageChannel

receive

public Message<String> receive()

Specified by:

receive in interface PollableChannel

receive

public Message<String> receive(long timeout)

Specified by:

receive in interface PollableChannel