Jupiter.Market.Elastic.Comparables.Services.ServiceBusMessageService
See the detailed conceptual article: ServiceBusMessageService Logic.
This service manages the lifecycle of deal messages sent to Azure Service Bus, including initialization, batching, retry logic, offset persistence, and statistics logging.
Methods
#ctor
Initializes a new instance of the #ctor class.
Parameters:
- indexerOptions: Indexer settings.
- serviceBusOptions: Service Bus settings.
- dataService: The data service for deal retrieval.
- logger: The logger instance.
- loggerHelper: The logger helper for conditional logging.
Jupiter.Market.Elastic.Comparables.Services.ServiceBusMessageService.InitAsync
No summary available.
GetDealsForServiceBusAsync
No summary available.
See the detailed conceptual article: ServiceBusMessageService Logic.
Parameters:
- usePriority: Whether to use priority query for deal selection.
- batchSize: The batch size for deal retrieval.
- cancellationToken: Cancellation token.
SendMessagesAsync
No summary available.
See the detailed conceptual article: ServiceBusMessageService Logic.
Parameters:
- deals: The deals to send.
- cancellationToken: Cancellation token.
LoadOffset
No summary available.
Parameters:
- path: The file path to load the offset from.
Returns: The loaded .
SaveOffset
No summary available.
Parameters:
- path: The file path to save the offset to.
- offset: The offset to save.
Jupiter.Market.Elastic.Comparables.Services.ServiceBusMessageService.LogServiceBusMessageServiceProgress
No summary available.