public static void stopPollingForMessages ( String queueURL ) { if ( ! StringUtils . isBlank ( queueURL ) && POLLING_THREADS . containsKey ( queueURL ) ) { logger . info ( "Stopping SQS river on queue {} ..." , queueURL ) ; POLLING_THREADS . get ( queueURL ) . cancel ( true ) ; POLLING_THREADS . remove ( queueURL ) ; } }
Stops the thread that has been polling for messages .