send method

@override void send(dynamic message)

Send a message through the transport

Implementation

@override
void send(dynamic message) {
  try {
    final jsonMessage = jsonEncode(message);
    _logger.debug('Queueing message: $jsonMessage');

    // Add message to queue
    _messageQueue.add(jsonMessage);

    // Start processing queue if not already doing so
    _processMessageQueue();
  } catch (e) {
    _logger.debug('Error encoding message: $e');
    _logger.debug('Original message: $message');
    rethrow;
  }
}