@override Future<void> ping(String topic) { try { return engine.ping(topic); } catch (error) { logger.e(error is ErrorResponse ? error.message : error.toString()); rethrow; } }