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

Class AzureServiceBusService

java.lang.Object

app.ductape.sdk.brokers.utils.providers.AzureServiceBusService

All Implemented Interfaces:

BrokerTypes.IMessageBrokerService

public final class AzureServiceBusService
extends Object
implements BrokerTypes.IMessageBrokerService

Azure Service Bus provider — parity with TS azure-servicebus.service.ts

Constructor Summary

Constructors

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

AzureServiceBusService

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