Mailing-List: contact user-help@curator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@curator.apache.org
MIME-Version: 1.0
In-Reply-To: <FF9B1612-CE9A-4D8B-9C18-9E3BD9D20404@jordanzimmerman.com>
References: 
 <CABpAV1ftLZnoerh-T6vv3CVoxRrXBCN7mQ33Py75bSJ16BfodQ@mail.gmail.com>
	<FF9B1612-CE9A-4D8B-9C18-9E3BD9D20404@jordanzimmerman.com>
Date: Thu, 31 Mar 2016 16:56:00 -0400
Message-ID: 
 <CALuNCphm6=_F7_e7kgFKxYAXHwQ1WVNtjeTMn-oavkkBVLbOmw@mail.gmail.com>
Subject: Re: TreeCache not working
From: Scott Blum <dragonsinth@gmail.com>
To: Jordan Zimmerman <jordan@jordanzimmerman.com>
Cc: user@curator.apache.org
Content-Type: multipart/alternative; boundary=001a11426cde5c8533052f5e7d99

--001a11426cde5c8533052f5e7d99
Content-Type: text/plain; charset=UTF-8

I took a cursory look but I've never used Scala.  Nothing seems obviously
wrong, so I'm not sure what to say?  I'm pretty sure TreeCache generally
works as intended.

On Thu, Mar 31, 2016 at 4:06 PM, Jordan Zimmerman <
jordan@jordanzimmerman.com> wrote:

> Scott, please have a look.
>
> On Mar 31, 2016, at 12:29 PM, Sakthipriyan Vairamani <
> sakthiprofessional@gmail.com> wrote:
>
> 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?
>
>
>

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

<div dir=3D"ltr">I took a cursory look but I&#39;ve never used Scala.=C2=A0=
 Nothing seems obviously wrong, so I&#39;m not sure what to say?=C2=A0 I=
9;m pretty sure TreeCache generally works as intended.</div><div class=3D"g=
mail_extra"><br><div class=3D"gmail_quote">On Thu, Mar 31, 2016 at 4:06 PM,=
 Jordan Zimmerman <span dir=3D"ltr">&lt;<a href=3D"mailto:jordan@jordanzimm=
erman.com" target=3D"_blank">jordan@jordanzimmerman.com</a>&gt;</span> wrot=
e:<br><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-l=
eft:1px #ccc solid;padding-left:1ex"><div style=3D"word-wrap:break-word"><d=
iv>Scott, please have a look.</div><div><div class=3D"h5"><br><div><blockqu=
ote type=3D"cite"><div>On Mar 31, 2016, at 12:29 PM, Sakthipriyan Vairamani=
 &lt;<a href=3D"mailto:sakthiprofessional@gmail.com" target=3D"_blank">sakt=
hiprofessional@gmail.com</a>&gt; wrote:</div><br><div><div dir=3D"ltr"><div=
 class=3D"gmail_default" style=3D"font-family:verdana,sans-serif;font-size:=
small"><pre style=3D"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 wh=
enever there is a change (addition, deletion, and updation) in the Node I a=
m watching. Following is the code I have,

    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>
</div></blockquote></div><br></div></div></div></blockquote></div><br></div=
>

--001a11426cde5c8533052f5e7d99--