upsertMessage method

Future<void> upsertMessage(
  1. LocalityEvent message
)

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

Implementation

Future<void> upsertMessage(LocalityEvent message) async {
  _messageQueue.add(message);

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