incoming method

@override Map<String, dynamic> incoming(Map<String, dynamic> message)

Process incoming messages

Implementation

@override
Map<String, dynamic> incoming(Map<String, dynamic> message) {
  _logger.info('CustomExtension: Processing incoming message: $message');

  if (incomingProcessor != null) {
    try {
      final processed = incomingProcessor!(message);
      _logger.info('CustomExtension: Incoming message processed: $processed');
      return processed;
    } catch (e) {
      _logger.severe('CustomExtension: Incoming processing failed: $e');
      return message;
    }
  }

  return message;
}