[xmlblaster] setPersistent() on DOMAIN and XPATH

["Sanjeev Dhiman" <sanjeevd at brickred.com>]

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>