onMessage method

@override Future<void> onMessage(dynamic message)

Handle incoming messages with command/event routing

Implementation

@override
Future<void> onMessage(dynamic message) async {
  // Handle state query before passing to base class
  if (message is ChannelStateQuery) {
    _handleStateQuery(message);
    return;
  }

  // Capture sender at start of message processing
  if (message is Command) {
    final sender = context.sender;
    if (sender != null) {
      _capturedSenders[message.commandId] = sender;
    }
  }
  await super.onMessage(message);
}