onMessage method

@override Future<void> onMessage(dynamic message)

Called when a message is received.

Implementation

@override
Future<void> onMessage(dynamic message) async {

  try {
    switch (message.runtimeType) {
      case InitiateChannelMessage:
        await _handleInitiateChannel(message as InitiateChannelMessage);
        break;
      case AcceptChannelMessage:
        await _handleAcceptChannel(message as AcceptChannelMessage);
        break;
      case RecordServerAcceptanceMessage:
        await _handleRecordServerAcceptance(message as RecordServerAcceptanceMessage);
        break;
      case BuildRefundTransactionMessage:
        await _handleBuildRefundTransaction(message as BuildRefundTransactionMessage);
        break;
      case SignRefundTransactionMessage:
        await _handleSignRefundTransaction(message as SignRefundTransactionMessage);
        break;
      case MultisigTransactionSignedResponse:
        await _handleMultisigSignedResponse(message as MultisigTransactionSignedResponse);
        break;
      case RecordRefundSignatureMessage:
        await _handleRecordRefundSignature(message as RecordRefundSignatureMessage);
        break;
      case OpenChannelMessage:
        await _handleOpenChannel(message as OpenChannelMessage);
        break;
      case RecordPaymentMessage:
        await _handleRecordPayment(message as RecordPaymentMessage);
        break;
      case AcknowledgePaymentMessage:
        await _handleAcknowledgePayment(message as AcknowledgePaymentMessage);
        break;
      case CloseChannelMessage:
        await _handleCloseChannel(message as CloseChannelMessage);
        break;
      case QueryChannelStateMessage:
        await _handleQueryChannelState(message as QueryChannelStateMessage);
        break;
      default:
    }
  } catch (e, stack) {

    // Send error response to sender if available
    if (context.sender != null) {
      _sendErrorResponse(message, e.toString());
    }
  }
}