RE: [xmlblaster] setPersistent() on DOMAIN and XPATH

2010-01-06 Thread Sanjeev Dhiman
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-xmlblas...@server.xmlblaster.org
[mailto:owner-xmlblas...@server.xmlblaster.org] On Behalf Of Marcel Ruff
Sent: Wednesday, January 06, 2010 8:19 PM
To: xmlblaster@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 :
>
>  
>
> subscribe 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 :
>
>  
>
>   
>
>  
>
/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/instanceId/126270
> 7403774
>
>timeout='8640' maxSessions='10' clearSessions='false'
> reconnectSameClientOnly='false'
> sessionId='sessionId:127.0.0.1-null-1262780265646-262620263-69'/>
>
>maxEntries='1000' maxEntriesCache='1000'>
>
>
>
> socket://169.130.94.125:7610
>
>
>
>   
>
>   
>
>maxEntriesCache='1000' maxBytes='4147483647'
maxBytesCache='200555666'>
>
> dispatchPlugin='undef'>
>
> socket://172.16.8.35:3446
>
>  
>
> 
type='String'>/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/client/engine7/
> session/1
>
>
>
>   
>
>   2010-01-06
12:17:45.431Z
>
>   2010-01-06
> 12:17:45.648Z
>
>  
>
>
>   


-- 
Marcel Ruff
http://www.xmlBlaster.org
http://watchee.net
Phone: +49 7551 309371



Re: [xmlblaster] setPersistent() on DOMAIN and XPATH

2010-01-06 Thread Marcel Ruff

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 :

 

subscribe 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 :

 

  

 
/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/instanceId/126270

7403774

  

  

   

socket://169.130.94.125:7610

   

  

  

  

   

socket://172.16.8.35:3446

 


/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/client/engine7/
session/1

   

  

  2010-01-06 12:17:45.431Z

  2010-01-06
12:17:45.648Z

 


  



--
Marcel Ruff
http://www.xmlBlaster.org
http://watchee.net
Phone: +49 7551 309371



[xmlblaster] setPersistent() on DOMAIN and XPATH

2010-01-06 Thread Sanjeev Dhiman
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 :

 

subscribe 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 :

 

  

 
/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/instanceId/126270
7403774

  

  

   

socket://169.130.94.125:7610

   

  

  

  

   

socket://172.16.8.35:3446

 

/xmlBlaster/node/xmlBlaster_127_0_0_1_3412/client/engine7/
session/1

   

  

  2010-01-06 12:17:45.431Z

  2010-01-06
12:17:45.648Z