Inject pausable channels

Author: ozangunalp

smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/extension/ChannelProducer.java

@@ -29,6 +29,7 @@
 import io.smallrye.reactive.messaging.ChannelRegistry;
 import io.smallrye.reactive.messaging.MessageConverter;
 import io.smallrye.reactive.messaging.MutinyEmitter;
+import io.smallrye.reactive.messaging.PausableChannel;
 import io.smallrye.reactive.messaging.providers.helpers.MultiUtils;
 import io.smallrye.reactive.messaging.providers.helpers.TypeUtils;
 import io.smallrye.reactive.messaging.providers.i18n.ProviderExceptions;
@@ -187,6 +188,17 @@ <T> MutinyEmitter<T> produceMutinyEmitter(InjectionPoint injectionPoint) {
         return getEmitter(injectionPoint);
     }
 
+    @Produces
+    @Channel("")
+    PausableChannel producePausableChannel(InjectionPoint injectionPoint) {
+        String name = getChannelName(injectionPoint);
+        PausableChannel channel = channelRegistry.getPausable(name);
+        if (channel == null) {
+            throw ex.pausableChannelNotFound(name);
+        }
+        return channel;
+    }
+
     /**
      * Injects an {@link io.smallrye.reactive.messaging.annotations.Emitter} (deprecated) matching the channel name.
      *

smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/i18n/ProviderExceptions.java

@@ -303,4 +303,7 @@ IllegalArgumentException illegalArgumentForWorkerConfigKey(String annotation, St
     @Message(id = 1008, value = "Emitter configuration for channel `%s` in %s is different than a previous configuration : %s")
     DefinitionException differentEmitterConfigurationPerInjection(String channel, String injectionPoint, String config);
 
+    @Message(id = 1009, value = "Unable to find a pausable channel with name `%s`")
+    DefinitionException pausableChannelNotFound(String name);
+
 }