Package io.awspring.cloud.sns.core

Class TopicMessageChannel

java.lang.Object

org.springframework.messaging.support.AbstractMessageChannel

io.awspring.cloud.sns.core.TopicMessageChannel

All Implemented Interfaces:

Aware, BeanNameAware, MessageChannel, InterceptableChannel

public class TopicMessageChannel
extends AbstractMessageChannel

Implementation of AbstractMessageChannel which is used for converting and sending messages via SnsClient to SNS.

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 inherited from class org.springframework.messaging.support.AbstractMessageChannel

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TopicMessageChannel(software.amazon.awssdk.services.sns.SnsClient snsClient, software.amazon.awssdk.arns.Arn topicArn)

Method Summary

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

Constructor Details

TopicMessageChannel

public TopicMessageChannel(software.amazon.awssdk.services.sns.SnsClient snsClient,
 software.amazon.awssdk.arns.Arn topicArn)

Method Details

sendInternal

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

Specified by:

sendInternal in class AbstractMessageChannel