Skip to content

Instantly share code, notes, and snippets.

@creese

creese/gist:7008cb444a042b894fa9 Secret

Created June 2, 2015 20:08
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save creese/7008cb444a042b894fa9 to your computer and use it in GitHub Desktop.
Save creese/7008cb444a042b894fa9 to your computer and use it in GitHub Desktop.
Download ZIP
java.lang.AssertionError: Assert failed: No more than 1024 pending puts are allowed on a single channel. Consider using a windowed buffer.
Raw
gistfile1.txt
DefaultExceptionHandler: Consumer langohr.consumers.proxy$com.rabbitmq.client.DefaultConsumer$ff19274a@314366f5 (amq.ctag-ho0msQie02vwYNrbhIsgkw) method handleDelivery for channel AMQChannel(amqp://keypradmin@127.0.0.1:5672/,1) threw an exception for channel AMQChannel(amqp://keypradmin@127.0.0.1:5672/,1):
java.lang.AssertionError: Assert failed: No more than 1024 pending puts are allowed on a single channel. Consider using a windowed buffer.
(< (.size puts) impl/MAX-QUEUE-SIZE)
at clojure.core.async.impl.channels.ManyToManyChannel.put_BANG_(channels.clj:150)
at clojure.core.async$put_BANG_.invoke(async.clj:145)
at keypr.core.event$in_que$handler__8821.invoke(event.clj:30)
at langohr.consumers$create_default$fn__8038.invoke(consumers.clj:84)
at langohr.consumers.proxy$com.rabbitmq.client.DefaultConsumer$ff19274a.handleDelivery(Unknown Source)
at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:144)
at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:99)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment