Package app.ductape.sdk.brokers

Class BrokersService

java.lang.Object

app.ductape.sdk.brokers.BrokersService

public class BrokersService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	BrokersService.Messages

Field Summary

Fields

Modifier and Type	Field	Description
final BrokersService.Messages	messages

Constructor Summary

Constructors

Constructor	Description
BrokersService(EnvType env, RequestContext auth)
BrokersService(RequestContext auth)
BrokersService(RequestContext auth, ProductsService productsService, ProcessorApiService processorApiService)
BrokersService(RequestContext auth, ProductsService productsService, ProcessorApiService processorApiService, LogApiService logApiService)

Method Summary

Modifier and Type	Method	Description
RequestContext	auth()
Map<String,Object>	checkIdempotency(Map<String,Object> options)
static void	clearSharedBrokerRegistry()	Visible for tests / lifecycle hooks: clear the workspace-scoped shared provider pool.
void	disconnectAll()	TS disconnectAll: best-effort disconnect on all pooled providers.
Map<String,Object>	getBroker(String productTag, String brokerTag)
List<Map<String,Object>>	getBrokers(String productTag)
Map<String,Object>	getEvent(Map<String,Object> options)
Map<String,Object>	getEvents(Map<String,Object> options)
Map<String,Object>	getEventStats(Map<String,Object> options)
Map<String,Object>	getTopic(String productTag, String event)
List<Map<String,Object>>	getTopics(String productTag, String brokerTag)
Map<String,Object>	publish(Map<String,Object> options)
Map<String,Object>	publishIdempotent(Map<String,Object> options)
Map<String,Object>	replayEvent(Map<String,Object> options)
Map<String,Object>	reprocessDLQ(Map<String,Object> options)
void	setBrokerServiceFactory(BrokerServiceFactory factory)	TS loadBrokerService parity: substitute the in-process broker provider factory.
void	setCacheManager(CacheManager cacheManager)	TS brokers.service.ts: optional CacheManager for publish idempotency when cache is set.
void	setSecretResolver(Function<String,String> secretResolver)	TS getSecretsService(): resolve broker config secrets prefixed with secret://....
Map<String,Object>	subscribe(Map<String,Object> options)	TS brokers.service.ts#subscribe parity entry point.
Map<String,Object>	subscribe(Map<String,Object> options, BrokerTypes.MessageCallback callback)	Typed in-process overload: equivalent to TS brokers.subscribe({ ..., callback }) where callback is the user message handler.
Map<String,Object>	testConnection(Map<String,Object> options)

Methods inherited from class java.lang.Object

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

Field Details

messages

public final BrokersService.Messages messages

Constructor Details

BrokersService

public BrokersService(RequestContext auth)

BrokersService

public BrokersService(EnvType env,
 RequestContext auth)

BrokersService

public BrokersService(RequestContext auth,
 ProductsService productsService,
 ProcessorApiService processorApiService)

BrokersService

public BrokersService(RequestContext auth,
 ProductsService productsService,
 ProcessorApiService processorApiService,
 LogApiService logApiService)

Method Details

auth

public RequestContext auth()

setCacheManager

public void setCacheManager(CacheManager cacheManager)

TS brokers.service.ts: optional CacheManager for publish idempotency when cache is set.

setBrokerServiceFactory

public void setBrokerServiceFactory(BrokerServiceFactory factory)

TS loadBrokerService parity: substitute the in-process broker provider factory. Defaults to ProviderFactory.create(app.ductape.sdk.brokers.types.BrokerTypes.MessageBrokerType, java.util.Map<java.lang.String, java.lang.Object>). Tests inject a fake to avoid live Kafka/RabbitMQ/etc.

setSecretResolver

public void setSecretResolver(Function<String,String> secretResolver)

TS getSecretsService(): resolve broker config secrets prefixed with secret://.... Pass a function that maps secret reference to plaintext.

publish

public Map<String,Object> publish(Map<String,Object> options)

subscribe

public Map<String,Object> subscribe(Map<String,Object> options)

TS brokers.service.ts#subscribe parity entry point.

Dispatches between two paths based on whether the caller supplied a BrokerTypes.MessageCallback:

• In-process (TS-equivalent): when options.callback is a MessageCallback (or when the typed overload subscribe(Map, MessageCallback) is used), the SDK resolves the broker provider locally via BrokerServiceFactory, wraps the user callback with TS-shape tracking (init/success logs + per-message registerBrokerConsumer / updateBrokerConsumerStatus fire-and-forget calls), and invokes provider.subscribe(topicUrl, wrappedCallback) directly.
• Processor-side: when no callback is provided, falls back to the existing processorApiService.processProduct(...) dispatch, which is what server-mediated consumers use today.

subscribe

public Map<String,Object> subscribe(Map<String,Object> options,
 BrokerTypes.MessageCallback callback)

Typed in-process overload: equivalent to TS brokers.subscribe({ ..., callback }) where callback is the user message handler. Uses BrokerServiceFactory to obtain the provider (e.g. Kafka/RabbitMQ/SQS/PubSub/Redis/Nats) and wires a wrapped callback that mirrors TS message-id extraction, fire-and-forget tracking, and re-throw semantics so the underlying provider can nack/retry.

disconnectAll

public void disconnectAll()

TS disconnectAll: best-effort disconnect on all pooled providers.

clearSharedBrokerRegistry

public static void clearSharedBrokerRegistry()

Visible for tests / lifecycle hooks: clear the workspace-scoped shared provider pool.

testConnection

public Map<String,Object> testConnection(Map<String,Object> options)

getBrokers

public List<Map<String,Object>> getBrokers(String productTag)

getBroker

public Map<String,Object> getBroker(String productTag,
 String brokerTag)

getTopics

public List<Map<String,Object>> getTopics(String productTag,
 String brokerTag)

getTopic

public Map<String,Object> getTopic(String productTag,
 String event)

getEvents

public Map<String,Object> getEvents(Map<String,Object> options)

getEvent

public Map<String,Object> getEvent(Map<String,Object> options)

replayEvent

public Map<String,Object> replayEvent(Map<String,Object> options)

getEventStats

public Map<String,Object> getEventStats(Map<String,Object> options)

reprocessDLQ

public Map<String,Object> reprocessDLQ(Map<String,Object> options)

checkIdempotency

public Map<String,Object> checkIdempotency(Map<String,Object> options)

publishIdempotent

public Map<String,Object> publishIdempotent(Map<String,Object> options)