> Sorry, i have forgotten to commit it - dust over my head ... -
> Could you try again?
Certes, good sir!
Unfortunately, if I use oids, I get:
[Jul 15, 2002 9:25:54 AM ERROR
MessageUnitHandler-/node/http:A.B.C.D:3412/msg/Group0.EmptyMessageUnit]
Internal problem, msgUnit = null, there was not yet any message published,
only subscription exists on this unpublished message:
<MessageUnitHandler>
<uniqueKey>Group0</uniqueKey>
<MessageUnitWrapper>null</MessageUnitWrapper>
<SubscriptionInfo id='__subId:2/>
<handlerIsNewCreated>false</handlerIsNewCreated>
</MessageUnitHandler>
java.lang.Throwable
at org.jutils.runtime.StackTrace.getStackTrace(StackTrace.java:50)
at
org.xmlBlaster.engine.MessageUnitHandler.getMessageUnitWrapper(MessageUnitHa
ndler.java:154)
at
org.xmlBlaster.engine.RequestBroker.publish(RequestBroker.java:1212)
at
org.xmlBlaster.engine.RequestBroker.publish(RequestBroker.java:1032)
at
org.xmlBlaster.engine.XmlBlasterImpl.publish(XmlBlasterImpl.java:138)
at
org.xmlBlaster.protocol.corba.ServerImpl.publish(ServerImpl.java:108)
at
org.xmlBlaster.protocol.corba.serverIdl.ServerPOA._invoke(ServerPOA.java:80)
at
org.jacorb.poa.RequestProcessor.invokeOperation(RequestProcessor.java:207)
at
org.jacorb.poa.RequestProcessor.process(RequestProcessor.java:404)
at org.jacorb.poa.RequestProcessor.run(RequestProcessor.java:513)
Although this happened a lot further down the track than previously (about
740 messages processed, rather than 10)
and if I use xpath, I get a stream of messages of the form
[Jul 15, 2002 9:40:20 AM INFO XmlKey] XPath subscription
'/xmlBlaster/key/Group0' matches message
'http_A_B_C_D_3412-1026690020615-70'
[Jul 15, 2002 9:40:20 AM WARN
MsgQueue-/node/http:A.B.C.D:3412/client/guest/3] The queue is shutdown,
putMsgs()of 1 messages failed, starting error handling ...
[Jul 15, 2002 9:40:20 AM WARN RequestBroker-/node/http:A.B.C.D:3412]
Generating dead letter oid=http_A_B_C_D_3412-1026690020615-70 from
publisher=guest because delivery to
'guest'cbQueue=/node/http:A.B.C.D:3412/client/guest/3 failed.
ending with
[Jul 15, 2002 9:36:52 AM ERROR RequestBroker-/node/http:A.B.C.D:3412]
Received exception on message erase event, we ignore it:
id=RequestBroker-/node/http:A.B.C.D:3412.NOT_REMOVED reason=Sorry, can't
remove message unit, because itdidn't exist:
http_A_B_C_D_3412-1026689683988-107
id=RequestBroker-/node/http:A.B.C.D:3412.NOT_REMOVED reason=Sorry, can't
remove message unit, because it didn't exist:
http_A_B_C_D_3412-1026689683988-107
at
org.xmlBlaster.engine.RequestBroker.messageErase(RequestBroker.java:1475)
at
org.xmlBlaster.engine.RequestBroker.fireMessageEraseEvent(RequestBroker.java
:1660)
at
org.xmlBlaster.engine.MessageUnitHandler.removeSubscriber(MessageUnitHandler
.java:333)
at
org.xmlBlaster.engine.SubscriptionInfo.removeSubscribe(SubscriptionInfo.java
:274)
at
org.xmlBlaster.engine.ClientSubscriptions.removeFromClientSubscriptionMap(Cl
ientSubscriptions.java:444)
at
org.xmlBlaster.engine.ClientSubscriptions.subscriptionRemove(ClientSubscript
ions.java:374)
at
org.xmlBlaster.engine.RequestBroker.fireSubscriptionEvent(RequestBroker.java
:1612)
at
org.xmlBlaster.engine.RequestBroker.fireUnSubscribeEvent(RequestBroker.java:
1584)
at
org.xmlBlaster.engine.RequestBroker.unSubscribe(RequestBroker.java:935)
at
org.xmlBlaster.engine.XmlBlasterImpl.unSubscribe(XmlBlasterImpl.java:109)
at
org.xmlBlaster.protocol.corba.ServerImpl.unSubscribe(ServerImpl.java:89)
at
org.xmlBlaster.protocol.corba.serverIdl.ServerPOA._invoke(ServerPOA.java:111
)
at
org.jacorb.poa.RequestProcessor.invokeOperation(RequestProcessor.java:207)
at
org.jacorb.poa.RequestProcessor.process(RequestProcessor.java:404)
at org.jacorb.poa.RequestProcessor.run(RequestProcessor.java:513)
Turning off volatile Qos fixes things again.
I've attached my current benchmark code, for your entertainment.
Attachment:
xmlBlaster-benchmarks.zip
Description: Binary data