don't try to stop consuming amqp when crawl is shutting down, can end up reopening the connection after it's been closed

2026-07-18 13:37:20 +00:00 · 2014-02-13 19:24:31 -08:00
parent 72b2d58034
commit e389499aa7
1 changed files with 1 additions and 1 deletions
@@ -272,7 +272,7 @@ public class AMQPUrlReceiver implements Lifecycle, ApplicationListener<CrawlStat
    @Override
    public void onApplicationEvent(CrawlStateEvent event) {
        switch(event.getState()) {
-        case PAUSING: case PAUSED: case STOPPING: case FINISHED:
+        case PAUSING: case PAUSED:
            try {
                channel().flow(false);
            } catch (IOException e) {