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

Class RabbitMQService

java.lang.Object

app.ductape.sdk.brokers.utils.providers.RabbitMQService

All Implemented Interfaces:

BrokerTypes.IMessageBrokerService

public final class RabbitMQService
extends Object
implements BrokerTypes.IMessageBrokerService

RabbitMQ provider runtime parity with TS rabbitmq.service.ts.

Constructor Summary

Constructors

Constructor	Description
RabbitMQService(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

RabbitMQService

public RabbitMQService(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