start method

Future<void> start()

Starts the STOMP server

Implementation

Future<void> start() async {
  if (_isRunning) {
    throw const StompStateException('Server already running', 'running', 'stopped');
  }

  // Register stream handler
  _host.setStreamHandler(StompProtocols.stomp, _handleNewConnection);
  _isRunning = true;

  _logger.info('STOMP server started on ${_host.id}');
}