[infinispan-issues] [JBoss JIRA] (ISPN-1637) AsyncStore.enqueue() throws 'CacheException: Unable to enqueue asynchronous task' Instead of blocking when the queue is full

AsyncStore.enqueue() throws 'CacheException: Unable to enqueue asynchronous task' Instead of blocking when the queue is full ---------------------------------------------------------------------------------------------------------------------------- Key: ISPN-1637 URL: https://issues.jboss.org/browse/ISPN-1637 Project: Infinispan Issue Type: Bug Components: Loaders and Stores Affects Versions: 5.1.0.CR1 Reporter: Andrew Pushkin Assignee: Manik Surtani Labels: blockingQueue, modificationQueueSize Fix For: 5.1.0.CR3 Original Estimate: 2 hours Remaining Estimate: 2 hours Documentation http://docs.jboss.org/infinispan/5.1/apidocs/config.html#ce_loader_async : "modificationQueueSize int 1024 Sets the size of the modification queue for the async store. If updates are made at a rate that is faster than the underlying cache store can process this queue, then the async store behaves like a synchronous store for that period, blocking until the queue can accept more elements. (Javadoc)" However the async store doesn't "behaves like synchronous [...] blocking until the queue can accept more elements" because AsyncStore.enqueue() calls changesDeque.add(mod); But I guess it should call put() to wait queue to accept more elements.