[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
RE: [xmlblaster] setPersistent() on DOMAIN and XPATH
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: owner-xmlblaster at server.xmlBlaster.org
[mailto:owner-xmlblaster at server.xmlBlaster.org] On Behalf Of Marcel Ruff
Sent: Wednesday, January 06, 2010 8:19 PM
To: xmlblaster at server.xmlBlaster.org
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