]
Manik Surtani updated ISPN-1637:
--------------------------------
Fix Version/s: 5.1.0.CR2
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.CR2
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.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: