selector = (String)StreamUtils.readObject(in, false);
String filterString = (String)StreamUtils.readObject(in, false);   filter = new Selector(filterString);
   public void read(DataInputStream in) throws Exception   {      nodeId = in.readUTF();            queueName = in.readUTF();            condition = in.readUTF();            active = in.readBoolean();            selector = (String)StreamUtils.readObject(in, false);            channelId = in.readLong();            durable = in.readBoolean();   }