尝试在网格增益中使用带有分布式队列的事务。在文档或 Java Doc 中找不到任何内容。
如果支持,有人可以分享一些示例代码吗?我尝试了以下代码,但它似乎不起作用。
这是我的测试代码:
GridCache<Object, Object> cache = g.cache("myCache");
GridCacheDataStructures dataStruct = cache.dataStructures();
GridCacheQueue<String> queue = dataStruct.queue("myQueue", 0, false, true);
GridCacheTx tx = cache.txStart();
.....queue.poll()...etc...
tx.commit();