title: is it possible to create a queue listener using web flux spring integration?
body: <pre class="lang-java prettyprint-override"><code>    @Component
      @RequiredArgsConstructor
      public class EventListener {
      
          private final EventProcessingService eventProcessingService;
  
          @JmsListener(destination = &quot;inputQueue&quot;, constainerFactory = &quot;myContainerFactory)
          public void receiveMessage(Message message) {
               eventProcessingService.doSome(message).subscribe(); // return Mono&lt;Void&gt;
          }
      }
      
  
  
       @Service
       public class EventProcessingService {
  
           public Mono&lt;Void&gt; doSome(Message message) {
              //...
           }
       }
    
      @Configuration
      @RequiredArgsConstructor
      public class MqIntegration {
          
          private final ConnectionFactory connectionFactory;
  
          @Bean
          public Publisher&lt;Message&lt;String&gt;&gt; mqReactiveFlow() {
              return IntegrationFlows
                  .from(Jms.messageDrivenChannelAdapter(this.connectionFactory)
                          .destination(&quot;testQueue&quot;))
                  .channel(MessageChannels.queue())
                  .toReactivePublisher();
          }
      }
  </code></pre>
  <p>I have some webflux application which interacts with ibm mq and a JmsListener which listens for messages from the queue when a message is received EventProcessingService makes requests to other services depending on the messages.
  I would like to know how I can create a JmsListener that works with reactive threads using Spring Integration. In other words I want to know if it is possible to create an Integration flow which will receive messages from the queue and call the EvenProcessingService when the messages are received so that it does not have a negative effect on the threads inside webflux application</p>