Package app.ductape.sdk.brokers.utils.providers

Class SQSService

java.lang.Object

app.ductape.sdk.brokers.utils.providers.SQSService

All Implemented Interfaces:

BrokerTypes.IMessageBrokerService

public final class SQSService
extends Object
implements BrokerTypes.IMessageBrokerService

AWS SQS provider runtime parity with TS aws-sqs.service.ts.

Constructor Summary

Constructors

Constructor	Description
SQSService(Map<String,Object> config)

Method Summary

Modifier and Type	Method	Description
void	connect()
void	disconnect()
void	publish(String topic, Map<String,Object> message)
void	subscribe(String topic, BrokerTypes.MessageCallback callback)

Methods inherited from class java.lang.Object

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

Constructor Details

SQSService

public SQSService(Map<String,Object> config)

Method Details

connect

public void connect()

Specified by:

connect in interface BrokerTypes.IMessageBrokerService

publish

public void publish(String topic,
 Map<String,Object> message)

Specified by:

publish in interface BrokerTypes.IMessageBrokerService

subscribe

public void subscribe(String topic,
 BrokerTypes.MessageCallback callback)

Specified by:

subscribe in interface BrokerTypes.IMessageBrokerService

disconnect

public void disconnect()

Specified by:

disconnect in interface BrokerTypes.IMessageBrokerService