init

fn-rabbitmq/src/main/java/net/yaoyi/pipeline/rabbitmq/RabbitConsumer.java

@@ -47,7 +47,11 @@ public class RabbitConsumer implements PojoRequestHandler<Map<String, Object>, V
         }
 
         try {
-            Thread.sleep(5 * 60 * 1000);
+            if (input.containsKey("waitSeconds")) {
+                Thread.sleep((int) input.get("waitSeconds") * 1000);
+            } else {
+                Thread.sleep(2 * 60 * 1000);
+            }
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         }