enqueue method

bool enqueue(
  1. WebSocketMessage message
)

Adds a message to the queue. Returns true if the message was added successfully.

Implementation

bool enqueue(WebSocketMessage message) {
  // Check if queue is full
  if (_queue.length >= maxSize) {
    return false;
  }

  // Check for duplicates if deduplication is enabled
  if (enableDeduplication && _messageIds.contains(message.id)) {
    return false;
  }

  // Add message to queue
  _queue.add(message);

  // Add message ID to deduplication set
  if (enableDeduplication) {
    _messageIds.add(message.id);
  }

  // Sort by priority if enabled
  if (enablePriority) {
    _sortByPriority();
  }

  return true;
}