@Test
public void delegatesClusterConnectionIfCluster() {

  RedisConnectionFactory connectionFactory = mock(RedisConnectionFactory.class);
  when(connectionFactory.getConnection()).thenReturn(mock(RedisClusterConnection.class));
  TracingRedisConnectionFactory tracingConnectionFactory = new TracingRedisConnectionFactory(
      connectionFactory,
      new TracingConfiguration.Builder(tracer).traceWithActiveSpanOnly(false).build());
  assertTrue(tracingConnectionFactory.getConnection() instanceof RedisClusterConnection);
}