title: spring-integration amqp reject message if not procced
body: <p>I need solve this scenario. I have two amqp consumer set to fetch one message. </p>
  
  <pre><code>@Bean
  public IntegrationFlow jmsPrimaryFlow() {
      return IntegrationFlows.from(
          Amqp.inboundGateway(
              taskManager().getPrimaryMessageListenerContainer()).errorChannel(errorChannel())
          )
          .channel(taskChannel())
          .get();
  }
  
  @Bean
  public IntegrationFlow jmsSecondaryFlow() {
      return IntegrationFlows.from(
          Amqp.inboundGateway(
              taskManager().getSecondaryMessageListenerContainer()).errorChannel(errorChannel())
              .autoStartup(false)
          )
          .channel(taskChannel())
          .get();
  }
  </code></pre>
  
  <p>taskChannel is queuechannel but allow only one message consume at once so no parallel processing.
  How can I reject one message after some timeout if another message took too long to proceed. 
  so this message will returned back to queue to proceed by another node? Just I mean that those two consumer prefetch two messages but only one can be processed at once so how release second prefetched message if the first one took to long to proceed. </p>