spring-cloud-aws-messaging/src/main/java/org/springframework/cloud/aws/messaging/listener/NonBlockingMessageListenerContainer.java
public void stop(String logicalQueueName) {
		stopQueue(logicalQueueName);

		try {
			if (isRunning(logicalQueueName)) {
				Future<?> future = this.scheduledFutureByQueue.remove(logicalQueueName);
				future.get(this.queueStopTimeout, TimeUnit.MILLISECONDS);
			}
		} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
		} catch (ExecutionException | TimeoutException e) {
			getLogger().warn("Error stopping queue with name: '" + logicalQueueName + "'", e);
		}
	}
/**
	 * Stops and waits until the specified queue has stopped. If the wait timeout specified by {@link SimpleMessageListenerContainer#getQueueStopTimeout()}
	 * is reached, the current thread is interrupted.
	 *
	 * @param logicalQueueName
	 * 		the name as defined on the listener method
	 */
Stops and waits until the specified queue has stopped. If the wait timeout specified by  SimpleMessageListenerContainer#getQueueStopTimeout()
is reached, the current thread is interrupted.

@param logicalQueueName
the name as defined on the listener method
Stops and waits until the specified queue has stopped . If the wait timeout specified by SimpleMessageListenerContainer#getQueueStopTimeout () is reached the current thread is interrupted . @param logicalQueueName the name as defined on the listener method
public void stop(String logicalQueueName) {
		stopQueue(logicalQueueName);
		try {
			if (isRunning(logicalQueueName)) {
				Future<?> future = this.scheduledFutureByQueue.remove(logicalQueueName);
				future.get(this.queueStopTimeout, TimeUnit.MILLISECONDS);
			}
		} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
		} catch (ExecutionException | TimeoutException e) {
			getLogger().warn("Error stopping queue with name: '" + logicalQueueName + "'", e);
		}
	}
public void stop ( String logicalQueueName ) { stopQueue ( logicalQueueName ) ; try { if ( isRunning ( logicalQueueName ) ) { Future < ? > future = this . scheduledFutureByQueue . remove ( logicalQueueName ) ; future . get ( this . queueStopTimeout , TimeUnit . MILLISECONDS ) ; } } catch ( InterruptedException e ) { Thread . currentThread ( ) . interrupt ( ) ; } catch ( ExecutionException | TimeoutException e ) { getLogger ( ) . warn ( "Error stopping queue with name: '" + logicalQueueName + "'" , e ) ; } }
Stops and waits until the specified queue has stopped.
Stops and waits until the specified queue has stopped .