upsertBroadcasts method

  1. @override
Future<void> upsertBroadcasts(
  1. List<Broadcast> broadcasts
)

Adds a Broadcast message to the queue for future processing. If message processing is not currently running, it starts processing the queue.

Implementation

@override
Future<void> upsertBroadcasts(List<Broadcast> broadcasts) async {
  _messageQueue.addAll(broadcasts);

  // Start processing the queue if not already running
  if (!_isTransactionRunning) {
    _startProcessingQueue();
  }
}