[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
RE: [xmlblaster] Subscriber getting first message only

To: <xmlblaster at server.xmlblaster.org>
Subject: RE: [xmlblaster] Subscriber getting first message only
From: "David Hooker" <dhooker at btrade.com>
Date: Mon, 7 Apr 2003 13:53:37 -0500
Reply-to: xmlblaster at server.xmlBlaster.org
Sender: owner-xmlblaster at server.xmlBlaster.org
Thread-index: AcL7tcAdWuf7IAykTcS5GeFVGJpakwBf3zAg
Thread-topic: [xmlblaster] Subscriber getting first message only
I modified the code you gave me below to match the API's I'm using, and
it seems to work fine.  All my standalone tests work fine.  It still
doesn't work from my real program.

Here's a look at the log output from xmlBlaster when I run using my real
program.  I'll add my own comments using ">>>>>"

==========

>>>>> Just started xmlBlaster. Snip the startup messages.
>>>>> "SocketShow" is a subscriber client.  He subscribes first.

[Apr 7, 2003 1:38:41 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/SocketShow/-2, session expires after
[ 24 h 0 millis ], 1 of 10 sessions are in use
.
[Apr 7, 2003 1:38:42 PM WARN
HandleRequest-/node/http_10_10_10_116_3412] Empty request ignored
10.10.10.116:1916 -> 10.10.10.116:3412

>>>>> "ProcessRouterCheckConnection" is just to test to see if
xmlBlaster is running.  It simply logs in and logs out.

[Apr 7, 2003 1:38:43 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/ProcessRouterCheckConnection/-3,
session expires after [ 24 h 0 millis ], 1 of 10 s
essions are in use.
[Apr 7, 2003 1:38:43 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Disconnecting client
/node/http_10_10_10_116_3412/client/ProcessRouterCheckConnection/-3,
instanceId=-3, secretSessionId=IIOP:01111533204D4106010E0
C
[Apr 7, 2003 1:38:43 PM INFO  XmlKey] DOM parsed the XmlKey
__sys__Logout
[Apr 7, 2003 1:38:43 PM INFO
TopicHandler-/node/http_10_10_10_116_3412/topic/__sys__Logout] New topic
is ready, history/maxEntries=2,
persistence/msgUnitStore/maxEntries=100000000
[Apr 7, 2003 1:38:43 PM INFO
SubjectInfo-4-/node/http_10_10_10_116_3412/client/ProcessRouterCheckConn
ection] Destroying SubjectInfo
/node/http_10_10_10_116_3412/client/ProcessRouterCheckConnection. Nobody
is logged in a
nd no queue entries available
[Apr 7, 2003 1:38:43 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
loginNameSubjectInfoMap has 3 entries and sessionInfoMap has 2 entries

>>>>> Here's the actual subscriber within my main program:

[Apr 7, 2003 1:38:43 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/ProcessRouterSubscriber/-4, session
expires after [ 24 h 0 millis ], 1 of 10 sessio
ns are in use.

>>>>> Here's the sending client "DocSender".  He logs in and publishes a
message, then logs out.

[Apr 7, 2003 1:39:02 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/DocSender/-5, session expires after
[ 24 h 0 millis ], 1 of 10 sessions are in use.

[Apr 7, 2003 1:39:02 PM INFO  XmlKey] DOM parsed the XmlKey
ProcessRouter-ALL
[Apr 7, 2003 1:39:02 PM INFO
TopicHandler-/node/http_10_10_10_116_3412/topic/ProcessRouter-ALL] New
topic is ready, history/maxEntries=10,
persistence/msgUnitStore/maxEntries=100000000
[Apr 7, 2003 1:39:02 PM INFO  XmlKey] XPath subscription
'/xmlBlaster/key[ at oid='ProcessRouter-ALL']' matches message
'ProcessRouter-ALL'
[Apr 7, 2003 1:39:02 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Disconnecting client /node/http_10_10_10_116_3412/client/DocSender/-5,
instanceId=-5, secretSessionId=IIOP:03111533204D4106010E0C
[Apr 7, 2003 1:39:02 PM INFO
SubjectInfo-6-/node/http_10_10_10_116_3412/client/DocSender] Destroying
SubjectInfo /node/http_10_10_10_116_3412/client/DocSender. Nobody is
logged in and no queue entries available
[Apr 7, 2003 1:39:02 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
loginNameSubjectInfoMap has 4 entries and sessionInfoMap has 3 entries
[ Connected to 10.10.10.116:1919 from local port 1924 ]

>>>>> When the subscriber in my main program ("ProcessRouterSubscriber")
gets the message from DocSender, he creates a publisher and re-publishes
the message with a different OID:

[Apr 7, 2003 1:39:04 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/ProcessRouterPublisher/-6, session
expires after [ 24 h 0 millis ], 1 of 10 session
s are in use.
[Apr 7, 2003 1:39:04 PM INFO  XmlKey] DOM parsed the XmlKey SocketShow
[Apr 7, 2003 1:39:04 PM INFO
TopicHandler-/node/http_10_10_10_116_3412/topic/SocketShow] New topic is
ready, history/maxEntries=10,
persistence/msgUnitStore/maxEntries=100000000
[ Connected to 10.10.10.116:1913 from local port 1927 ]

>>>>> Now here's a strange message... No one has actually attempted to
unsubscribe yet!

[Apr 7, 2003 1:39:04 PM WARN
RequestBroker-/node/http_10_10_10_116_3412] UnSubscribe of
__subId:XPATH3 failed

>>>>> The publisher in my main program is done, so he disconnects:

[Apr 7, 2003 1:39:04 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Disconnecting client
/node/http_10_10_10_116_3412/client/ProcessRouterPublisher/-6,
instanceId=-6, secretSessionId=IIOP:04111533204D4106010E0C
[Apr 7, 2003 1:39:04 PM INFO
SubjectInfo-7-/node/http_10_10_10_116_3412/client/ProcessRouterPublisher
] Destroying SubjectInfo
/node/http_10_10_10_116_3412/client/ProcessRouterPublisher. Nobody is
logged in and no queue
entries available
[Apr 7, 2003 1:39:04 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
loginNameSubjectInfoMap has 4 entries and sessionInfoMap has 3 entries


>>>>> 30 seconds later, I run the DocSender publisher again.  Both of
the other subscribers (my main one "ProcessRouterSubscriber" and the
"SocketShow") should still be connected.
>>>>> DocSender connects again and publishes a new message:

[Apr 7, 2003 1:39:34 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Successful login for client
/node/http_10_10_10_116_3412/client/DocSender/-7, session expires after
[ 24 h 0 millis ], 1 of 10 sessions are in use.
[Apr 7, 2003 1:39:34 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Disconnecting client /node/http_10_10_10_116_3412/client/DocSender/-7,
instanceId=-7, secretSessionId=IIOP:05111533204D4106010E0C
[Apr 7, 2003 1:39:34 PM INFO
SubjectInfo-8-/node/http_10_10_10_116_3412/client/DocSender] Destroying
SubjectInfo /node/http_10_10_10_116_3412/client/DocSender. Nobody is
logged in and no queue entries available
[Apr 7, 2003 1:39:34 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
loginNameSubjectInfoMap has 4 entries and sessionInfoMap has 3 entries

>>>>> Now, why did this subscriber get disconnected???  My code NEVER
called unsubscribe or disconnect!!!

[Apr 7, 2003 1:39:34 PM WARN
DeliveryConnection-callback:/node/http_10_10_10_116_3412/client/ProcessR
outerSubscriber/-4] Connection transition ALIVE -> DEAD: retryCounter=0,
maxRetries=0
[Apr 7, 2003 1:39:34 PM WARN
RequestBroker-/node/http_10_10_10_116_3412] Generating dead message
'callback:/node/http_10_10_10_116_3412/client/ProcessRouterSubscriber/-4
/NORM/1049740774204000000' from publisher=/node/ht
tp_10_10_10_116_3412/client/DocSender/-7 because delivery with queue
'null' failed: XmlBlasterException
errorCode=[communication.noConnection.dead]
node=[http_10_10_10_116_3412] location=[CallbackCorbaDriver] message=[CO
RBA Callback of 1 messages to client [unknown] failed :
org.omg.CORBA.OBJECT_NOT_EXIST: This exception was reported by the
server, it is only re-thrown here.  vmcid: 0x0  minor code: 0
completed: No]
[Apr 7, 2003 1:39:34 PM INFO  XmlKey] DOM parsed the XmlKey
__sys__deadMessage
[Apr 7, 2003 1:39:34 PM INFO
TopicHandler-/node/http_10_10_10_116_3412/topic/__sys__deadMessage] New
topic is ready, history/maxEntries=10,
persistence/msgUnitStore/maxEntries=100000000
[Apr 7, 2003 1:39:34 PM WARN
MsgErrorHandler-/node/http_10_10_10_116_3412/client/ProcessRouterSubscri
ber/-4] Callback server is lost, killing login session of client
callback:/node/http_10_10_10_116_3412/client/ProcessR
outerSubscriber/-4: XmlBlasterException
errorCode=[communication.noConnection.dead]
node=[http_10_10_10_116_3412] location=[CallbackCorbaDriver]
message=[CORBA Callback of 1 messages to client [unknown] failed :
org.omg.
CORBA.OBJECT_NOT_EXIST: This exception was reported by the server, it is
only re-thrown here.  vmcid: 0x0  minor code: 0  completed: No]
[Apr 7, 2003 1:39:34 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
Disconnecting client
/node/http_10_10_10_116_3412/client/ProcessRouterSubscriber/-4,
instanceId=-4, secretSessionId=IIOP:02111533204D4106010E0C
[Apr 7, 2003 1:39:34 PM INFO
SubjectInfo-5-/node/http_10_10_10_116_3412/client/ProcessRouterSubscribe
r] Destroying SubjectInfo
/node/http_10_10_10_116_3412/client/ProcessRouterSubscriber. Nobody is
logged in and no queu
e entries available
[Apr 7, 2003 1:39:34 PM INFO  Authenticate-/node/http_10_10_10_116_3412]
loginNameSubjectInfoMap has 3 entries and sessionInfoMap has 2 entries
[Apr 7, 2003 1:40:34 PM WARN
TopicHandler-/node/http_10_10_10_116_3412/topic/__sys__deadMessage] 0
TopicHandler removed from persistency
[Apr 7, 2003 1:40:36 PM INFO
TopicHandler-/node/http_10_10_10_116_3412/topic/__sys__deadMessage]
Topic reached state DEAD. 0 history entries are destroyed.
Prev by Date: [xmlblaster] about the test about xmlBlaster
Next by Date: RE: [xmlblaster] Subscriber getting first message only
Previous by thread: Re: [xmlblaster] Subscriber getting first message only
Next by thread: RE: [xmlblaster] Subscriber getting first message only
Index(es):
- Date
- Thread