Mailing-List: contact user-help@curator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@curator.apache.org
MIME-Version: 1.0
From: Sakthipriyan Vairamani <sakthiprofessional@gmail.com>
Date: Thu, 31 Mar 2016 22:59:46 +0530
Message-ID: 
 <CABpAV1ftLZnoerh-T6vv3CVoxRrXBCN7mQ33Py75bSJ16BfodQ@mail.gmail.com>
Subject: TreeCache not working
To: user@curator.apache.org
Content-Type: multipart/alternative; boundary=94eb2c0a7ce2f77de5052f5b9c03

--94eb2c0a7ce2f77de5052f5b9c03
Content-Type: text/plain; charset=UTF-8

I am using Apache Curator Recipes v2.10.0, with Scala 2.11.8. I want
to be notified whenever there is a change (addition, deletion, and
updation) in the Node I am watching. Following is the code I have,

    curatorClient = CuratorFrameworkFactory.newClient("proper
Connection String"),
      new ExponentialBackoffRetry(1000, 3))
    curatorClient.start()

    treeCache = new TreeCache(curatorClient, "/a")
    treeCache.start()

    treeCache.getListenable.addListener(new TreeCacheListener {
      override def childEvent(client: CuratorFramework, event:
TreeCacheEvent): Unit = {

        event.getType match {
          case TreeCacheEvent.Type.NODE_ADDED => ERROR("TreeNode added: "
            + ZKPaths.getNodeFromPath(event.getData.getPath) + ", value: "
            + new String(event.getData.getData))
          case TreeCacheEvent.Type.NODE_UPDATED => ERROR("TreeNode Updated: "
            + ZKPaths.getNodeFromPath(event.getData.getPath) + ", value: "
            + new String(event.getData.getData))
          case TreeCacheEvent.Type.NODE_REMOVED => ERROR("TreeNode Removed: "
            + ZKPaths.getNodeFromPath(event.getData.getPath) + ", value: "
            + new String(event.getData.getData));
          case ex: TreeCacheEvent.Type => ERROR(s"Received Event [$ex]")
        }

      }
    })

Now, the only message I get from this is

    Received Event [INITIALIZED]

Nothing else. I tried adding nodes to /a through zkCli and also
through the program (I use util-zk library for inserting). What am I
missing?

--94eb2c0a7ce2f77de5052f5b9c03
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div class=3D"gmail_default" style=3D"font-family:verdana,=
sans-serif;font-size:small"><pre style=3D"color:rgb(0,0,0);word-wrap:break-=
word;white-space:pre-wrap">I am using Apache Curator Recipes v2.10.0, with =
Scala 2.11.8. I want to be notified whenever there is a change (addition, d=
eletion, and updation) in the Node I am watching. Following is the code I h=
ave,

    curatorClient =3D CuratorFrameworkFactory.newClient(&quot;proper Connec=
tion String&quot;),
      new ExponentialBackoffRetry(1000, 3))
    curatorClient.start()

    treeCache =3D new TreeCache(curatorClient, &quot;/a&quot;)
    treeCache.start()

    treeCache.getListenable.addListener(new TreeCacheListener {
      override def childEvent(client: CuratorFramework, event: TreeCacheEve=
nt): Unit =3D {

        event.getType match {
          case TreeCacheEvent.Type.NODE_ADDED =3D&gt; ERROR(&quot;TreeNode =
added: &quot;
            + ZKPaths.getNodeFromPath(event.getData.getPath) + &quot;, valu=
e: &quot;
            + new String(event.getData.getData))
          case TreeCacheEvent.Type.NODE_UPDATED =3D&gt; ERROR(&quot;TreeNod=
e Updated: &quot;
            + ZKPaths.getNodeFromPath(event.getData.getPath) + &quot;, valu=
e: &quot;
            + new String(event.getData.getData))
          case TreeCacheEvent.Type.NODE_REMOVED =3D&gt; ERROR(&quot;TreeNod=
e Removed: &quot;
            + ZKPaths.getNodeFromPath(event.getData.getPath) + &quot;, valu=
e: &quot;
            + new String(event.getData.getData));
          case ex: TreeCacheEvent.Type =3D&gt; ERROR(s&quot;Received Event =
[$ex]&quot;)
        }

      }
    })

Now, the only message I get from this is

    Received Event [INITIALIZED]

Nothing else. I tried adding nodes to /a through zkCli and also through the=
 program (I use util-zk library for inserting). What am I missing?</pre></d=
iv></div>

--94eb2c0a7ce2f77de5052f5b9c03--