Details
-
Bug
-
Resolution: Obsolete
-
Major
-
None
-
None
Description
I have a cluster of 2 nodes with the following configuration:
<replicated-cache name="memcachedCache" start="EAGER" mode="ASYNC" batching="false" queue-size="1000" queue-flush-interval="15000"> </replicated-cache>
The following code (MemcachedHelper is a memcached client)
mc1 = new MemcachedHelper(server1.getMemcachedEndpoint().getInetAddress().getHostName(), server1.getMemcachedEndpoint().getPort()); mc2 = new MemcachedHelper(server2.getMemcachedEndpoint().getInetAddress().getHostName(), server2.getMemcachedEndpoint().getPort()); mc1.set("key1", "value1"); assertTrue(null != mc1.get("key1")); assertTrue(null == mc2.get("key1"));
fails on the 2nd assert, because the entry is retrieved.
According to logs (attached), the replication queue is correctly flushed after 15 seconds with 1 element (and happens after the gets).
Works correctly with hotrod (entry is replicated only after the flush happens).
Attachments
Issue Links
- is blocked by
-
ISPN-3371 Add an non-tx distribution interceptor optimised for non-concurrent and async usage
- Resolved