io.awspring.cloud.messaging.core

Class TopicMessageChannel

java.lang.Object

org.springframework.messaging.support.AbstractMessageChannel

io.awspring.cloud.messaging.core.TopicMessageChannel

All Implemented Interfaces:

Aware, BeanNameAware, MessageChannel, InterceptableChannel

public class TopicMessageChannel
extends AbstractMessageChannel

Since:

1.0

Author:

Agim Emruli, Alain Sahli, Gyozo Papp

Nested Class Summary

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

AbstractMessageChannel.ChannelInterceptorChain

Field Summary

Fields

Modifier and Type	Field and Description
static String	MESSAGE_DEDUPLICATION_ID_HEADER Message Deduplication id for SNS message.
static String	MESSAGE_GROUP_ID_HEADER Message group id for SNS message (applies only to FIFO topic).
static String	NOTIFICATION_SUBJECT_HEADER Header name.

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
TopicMessageChannel(com.amazonaws.services.sns.AmazonSNS amazonSns, String topicArn)

Method Summary

Modifier and Type	Method and Description
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

Field Detail

NOTIFICATION_SUBJECT_HEADER

public static final String NOTIFICATION_SUBJECT_HEADER

Header name.

See Also:

Constant Field Values

MESSAGE_GROUP_ID_HEADER

public static final String MESSAGE_GROUP_ID_HEADER

Message group id for SNS message (applies only to FIFO topic).

See Also:

Constant Field Values

MESSAGE_DEDUPLICATION_ID_HEADER

public static final String MESSAGE_DEDUPLICATION_ID_HEADER

Message Deduplication id for SNS message.

See Also:

Constant Field Values

Constructor Detail

TopicMessageChannel

public TopicMessageChannel(com.amazonaws.services.sns.AmazonSNS amazonSns,
                           String topicArn)

Method Detail

sendInternal

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

Specified by:

sendInternal in class AbstractMessageChannel