diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/connectors/WorkerPoolRegistry.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/connectors/WorkerPoolRegistry.java index ad078d6986..4ac10af7cb 100644 --- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/connectors/WorkerPoolRegistry.java +++ b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/connectors/WorkerPoolRegistry.java @@ -39,10 +39,10 @@ public class WorkerPoolRegistry { private static final String WORKER_CONCURRENCY = "max-concurrency"; @Inject - private Instance executionHolder; + Instance executionHolder; @Inject - private Instance configInstance; + Instance configInstance; private final Map workerConcurrency = new HashMap<>(); private final Map workerExecutors = new ConcurrentHashMap<>(); diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/impl/ConfiguredChannelFactory.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/impl/ConfiguredChannelFactory.java index 8f1d993dd9..2f554b8dea 100644 --- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/impl/ConfiguredChannelFactory.java +++ b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/impl/ConfiguredChannelFactory.java @@ -35,7 +35,7 @@ public class ConfiguredChannelFactory implements ChannelRegistar { private final ConnectorFactories factories; @Inject - private Instance publisherDecoratorInstance; + Instance publisherDecoratorInstance; // CDI requirement for normal scoped beans protected ConfiguredChannelFactory() { diff --git a/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java b/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java index 13b73f9a68..cb8de66115 100644 --- a/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java +++ b/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java @@ -161,11 +161,11 @@ private enum ChannelStatus { @Inject @Any - private Instance clientOptions; + Instance clientOptions; @Inject @Any - private Instance credentialsProviders; + Instance credentialsProviders; RabbitMQConnector() { // used for proxies