@Test void createShouldFailWhenConnectionCantBeDone() { RabbitMQConfiguration rabbitMQConfiguration = RabbitMQConfiguration.builder() .amqpUri(URI.create("amqp: .managementUri(URI.create("http: .managementCredentials(DEFAULT_MANAGEMENT_CREDENTIAL) .maxRetries(1) .minDelayInMs(1) .build(); RabbitMQConnectionFactory rabbitMQConnectionFactory = new RabbitMQConnectionFactory(rabbitMQConfiguration); assertThatThrownBy(rabbitMQConnectionFactory::create) .isInstanceOf(RuntimeException.class); }
Connection create() { return connectionMono().block(); }
RabbitMQConnectionFactory { Connection create() { return connectionMono().block(); } }
RabbitMQConnectionFactory { Connection create() { return connectionMono().block(); } @Inject  RabbitMQConnectionFactory(RabbitMQConfiguration rabbitMQConfiguration); }
RabbitMQConnectionFactory { Connection create() { return connectionMono().block(); } @Inject  RabbitMQConnectionFactory(RabbitMQConfiguration rabbitMQConfiguration);  }
RabbitMQConnectionFactory { Connection create() { return connectionMono().block(); } @Inject  RabbitMQConnectionFactory(RabbitMQConfiguration rabbitMQConfiguration);   }