Package app.ductape.sdk.brokers.types

Interface BrokerTypes.IMessageBrokerService

All Known Implementing Classes:

AzureServiceBusService, GooglePubSubService, KafkaService, NatsService, RabbitMQService, RedisService, SQSService

Enclosing class:

BrokerTypes

public static interface BrokerTypes.IMessageBrokerService

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)

Method Details

connect

void connect()

publish

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

subscribe

void subscribe(String topic,
 BrokerTypes.MessageCallback callback)

disconnect

void disconnect()