[jira] [Resolved] (CURATOR-224) Locking Not Working with DistributedIdQueue

["Cameron McKenzie (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CURATOR-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Cameron McKenzie resolved CURATOR-224.
--------------------------------------
       Resolution: Fixed
    Fix Version/s:     (was: awaiting-response)
                   2.9.0

> Locking Not Working with DistributedIdQueue
> -------------------------------------------
>
>                 Key: CURATOR-224
>                 URL: https://issues.apache.org/jira/browse/CURATOR-224
>             Project: Apache Curator
>          Issue Type: Bug
>          Components: Apache, Framework
>    Affects Versions: 2.8.0
>         Environment: Windows 7/Java 8
>            Reporter: Zhihong Zhang
>            Priority: Blocker
>             Fix For: 2.9.0
>
>
> The locking doesn't work with DistributedIdQeue.
>     2015-06-18 17:19:47.859  INFO 18244 --- [    TaskCache-0] com.pixia.gi.zookeeper.TaskLockingQueue  : Path cache event: path=/task_queue/queue-|7qb89wjddu|0000000001, type=CHILD_REMOVED
>     2015-06-18 17:19:47.864  INFO 18244 --- [    TaskCache-0] com.pixia.gi.zookeeper.TaskLockingQueue  : Path cache event: path=/task_queue/queue-0000000005, type=CHILD_ADDED
> When the DistributedQueue does the requeue, it recreates a new node path without the ID. The bug is in following code block,
>             if ( requeue )
>             {
>                 client.inTransaction()
>                     .delete().forPath(itemPath)
>                     .and()
>                     .create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).forPath(makeItemPath(), bytes)
>                     .and()
>                     .commit();
>             }
> Should replace makeItemPath() with itemPath.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)