open method

  1. @override
Future open(
  1. String? correlationId
)

Opens the component.

  • correlationId (optional) transaction id to trace execution through call chain. Return Future that receives null no errors occured. Throws error

Implementation

@override
Future open(String? correlationId) async {
  var connection = await _connectionResolver.resolve(correlationId);
  if (connection == null) {
    throw ConfigException(
        correlationId, 'NO_CONNECTION', 'Connection is not configured');
  }
  //credential = await _credentialResolver.lookup(correlationId);

  var redisConn = redis.RedisConnection();

  //TODO: Fix work with uri connection string and credentials
  // if (connection.getUri() != null) {
  //   var url = connection.getUri();
  // } else {
  var host = connection.getHost() ?? 'localhost';
  var port = connection.getPort() ?? 6379;
  _client = await redisConn.connect(host, port);

  // }

  // if (credential != null) {
  //   var password = credential.getPassword();
  // }
}