Hi Marcel - there one more thing I observed. If my client is subscribed on DOMAIN, the server doesn't push any new message to it even if a publisher publishes the message on the same DOMAIN. But if I reconnect with a new session name (on DOMAIN only) then all the messages are pushed by the server including the last one too.
Please note - this behavior is not present with XPATH subscription. If my client is subscribed on XPATH and waiting for new messages, suppose a publisher publishes a new message then that message is pushed to my client by the server instantaneously. Seems like there is some bug in DOMAIN subscription. -----Original Message----- From: [email protected] [mailto:[email protected]] On Behalf Of Marcel Ruff Sent: Wednesday, January 06, 2010 8:19 PM To: [email protected] Subject: Re: [xmlblaster] setPersistent() on DOMAIN and XPATH Hi Sanjeev, thank you for reporting, it looks like a bug. I'll come back on it as soon as we have analyzed the problem, Marcel Sanjeev Dhiman schrieb: > Hi, > > While working on XMLBlaster as a client, when I get subscribed on a > server on a specific DOMAIN (and not on XPATH) and call > setPersistent(true) I get following error and my subscription gets > failed. Subscribing on XPATH works 100% fine. > > > > Any help is highly appreciated. > > > > subscribe key : > > <key domain='AK-511' queryType='DOMAIN'/> > > subscribe QoS : > > <qos> > > <persistent/> > > <isSubscribe/> > > </qos> > > 17:48:01,463 ERROR MyListener:86 - DIT_XMLBLASTER_EXCEPTION[problem in > subscribing...] > > errorCode=internal.unknown message=#exported > errorCode=internal.subscribe: An internal error occurred when processing > a subscribe() request. : java.lang.ClassCastException: > org.xmlBlaster.util.key.MsgKeyData cannot be cast to > org.xmlBlaster.util.key.QueryKeyData > > at > org.xmlBlaster.util.XmlBlasterException.parseByteArr(XmlBlasterException > .java:706) > > at > org.xmlBlaster.util.xbformat.MsgInfo.getException(MsgInfo.java:608) > > at > org.xmlBlaster.util.protocol.RequestReplyExecutor.receiveReply(RequestRe > plyExecutor.java:613) > > at > org.xmlBlaster.client.protocol.socket.SocketCallbackImpl.run(SocketCallb > ackImpl.java:351) > > at java.lang.Thread.run(Thread.java:619) > > Jan 6, 2010 5:48:01 PM org.xmlBlaster.client.XmlBlasterAccess connect > > INFO: 1.6.4 #exported: Successful SOCKET login as > /node/xmlBlaster_127_0_0_1_3412/client/engine7/1 > > ConnectReturn Qos : > > <qos> > > <securityService type="htpasswd" version="1.0"><![CDATA[ > > <user>engine7</user> > > <passwd>secret</passwd> > > ]]></securityService> > > > <instanceId>/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/instanceId/126270 > 7403774</instanceId> > > <session name='/node/xmlBlaster_127_0_0_1_3412/client/engine7/1' > timeout='86400000' maxSessions='10' clearSessions='false' > reconnectSameClientOnly='false' > sessionId='sessionId:127.0.0.1-null-1262780265646-262620263-69'/> > > <queue relating='connection' type='RAM' version='1.0' > maxEntries='10000000' maxEntriesCache='1000'> > > <address type='SOCKET' dispatchPlugin='undef'> > > socket://169.130.94.125:7610 > > </address> > > </queue> > > <queue relating='subject' type='RAM' version='1.0'/> > > <queue relating='callback' type='RAM' version='1.0' maxEntries='1000' > maxEntriesCache='1000' maxBytes='4147483647' maxBytesCache='200555666'> > > <callback type='SOCKET' retries='-1' delay='60000' > dispatchPlugin='undef'> > > socket://172.16.8.35:3446 > > > > <attribute name='__ContextNode' > type='String'>/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/client/engine7/ > session/1</attribute> > > </callback> > > </queue> > > <clientProperty name='__UTC'>2010-01-06 12:17:45.431Z</clientProperty> > > <clientProperty name='__rcvTimestampStr'>2010-01-06 > 12:17:45.648Z</clientProperty> > > </qos> > > > -- Marcel Ruff http://www.xmlBlaster.org http://watchee.net Phone: +49 7551 309371
