I have a code which is producing events to zookeeper in which consumer is null and then I have separate code in separate project in which I have consumer. We don't need "deserialize" code when we are sending data to zookeeper right? That's why I have removed it to show case the problem. I can add it but that deserialize method won't be called from the code which is producing the events since I have set consumer to null.
On Wed, Sep 23, 2015 at 2:32 PM, Martin Serrano <[email protected]> wrote: > I'm confused. How can this possibly work without deserialize code? > That shouldn't even compile. > > -Martin > > On 09/23/2015 05:12 PM, Check Peck wrote: > >Does anyone have any thoughts on this? > >>On Fri, Sep 18, 2015 at 9:39 PM, Check Peck <[email protected] > >wrote: > >>>I am seeing very weird issue when using DistributedQueue recipe in > >>Curator. I am thinking it might be a bug in Zookeeper or Curator but not > >>sure yet or may be I am doing something silly. > >>>>I am trying to queue message in Zookeeper using DistributedQueue > recipe: > >>>>public void queueMessages() throws Exception { > >>// below is the data I am sending > >>DqTestHolder work = new DqTestHolder("103", " > >>[email protected]", "K15O"); > >>this.queue.put(work); > >>} > >>>>And here is my serializer class: > >>>>public class DqTestHolderSerializer implements > >>QueueSerializer<DqTestHolder>{ > >>>>@Override > >>public DqTestHolder deserialize(byte[]buffer) { > >>// nothing here for now > >>} > >>>>@Override > >>public byte[]serialize(DqTestHolder work) { > >>return work.toString().getBytes(); > >>} > >>} > >>>>And here is my DqTestHolder class: > >>>>public class DqTestHolder { > >>private final String clientId; > >>private final String emailId; > >>private final String clientName; > >>>>public DqTestHolder(final String clientId, final String emailId, > >>final String clientName) { > >>this.clientId = clientId; > >>this.emailId = emailId; > >>this.clientName = clientName; > >>} > >>>>// getters here > >>>>public String toString() { > >>return this.clientId + "=" + this.emailId + "=" + > >>this.clientName; > >>} > >>} > >>>>Now after I queue above data and I go and see exhibitor, I am seeing > >>something like this: You see it is appending bracket ")" infront of data > >>and sometimes I see "(" this as well which is not what I am sending > above. > >>>>)[email protected]=K15O > >>>>This is only happening when we send data with "-" in it I guess and if > we > >>have something like this in emailId - "[email protected]" then I don't see > >>any bracket and it shows correctly what I am sending. So if anyone tried > to > >>get data using getData() method, I get exactly what I see in exhibitor > but > >>not what I have sent above. > >>>>Also when we try to use getData() method of curator to get above data > from > >>znode, I see some wierd characters getting appended to it as well. I am > >>using Curator 2.8.0 > >>>>>> >
