[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[xmlblaster] problems with sending PtP oneway messages in cluster environment



I have the following clustering setup:


Client --publishOneway---> djmproxy ---> psq
                                       - Security Plugin
  <---------PtP publish oneway----------------|


In the Master's security plugin, I use the following code to get 
the sender ID out of a MsgUnit

    private SessionName getSender (MsgUnit msgUnit) {
	QosData qd = msgUnit.getQosData();
	if (qd instanceof MsgQosData) {
	    return ((MsgQosData)qd).getSender();
	} else {
	    log.warn (ME, "cannot can sender from non MsgQosData");
	}
	return null;
    }

I'm trying to send a PtP message from the security plugin back to the
Client (which I assume I can do by putting whatever getSender returns
in as a destination to PublishQos). This happens in 
com.bbn.quo.dpasa.quorum.PSQNativeClient.sendPubReply(PSQNativeClient.java:226)
(see stack trace below). The connection I'm using to send the PtP
oneway message back to the client is retrieved via
 glob.getXmlblasterAccess()
which should return the "native access handle". Do I still have to
call connect on this native access handle ? I'll try this next.

Any clues as to what could be the reason for this exception ?


----
 [May 19, 2003 3:45:26 PM TRACE CorbaConnection-/node/psq_xxx.xxx.xxx.xxx/client/djmproxy_xxx.xxx.xxx.xxx/1] XmlBlasterException: IDL:org.xmlBlaster.protocol.corba/serverIdl/XmlBlasterException:1.0
[May 19, 2003 3:45:26 PM TRACE DeliveryConnection-client:client/djmproxy_xxx.xxx.xxx.xxx/1] Connection transition ALIVE -> toReconnected=true byDeliveryConnectionsHandler=true
[May 19, 2003 3:45:26 PM CALL  DeliveryManager-client:client/djmproxy_xxx.xxx.xxx.xxx/1] Sync delivery failed connection state is ALIVE: errorCode=user.notConnected message=Your operation is not possible, please login with connect() f
irst
[May 19, 2003 3:45:26 PM TRACE XmlBlasterAccess-client/djmproxy_xxx.xxx.xxx.xxx/1] errorCode=user.notConnected message=Your operation is not possible, please login with connect() first
errorCode=user.notConnected message=Your operation is not possible, please login with connect() first
        at org.xmlBlaster.protocol.corba.CorbaDriver.convert(CorbaDriver.java:530)
        at org.xmlBlaster.client.protocol.corba.CorbaConnection.publishArr(CorbaConnection.java:714)
        at org.xmlBlaster.client.dispatch.ClientDeliveryConnection.publish(ClientDeliveryConnection.java:188)
        at org.xmlBlaster.client.dispatch.ClientDeliveryConnection.doSend(ClientDeliveryConnection.java:118)
        at org.xmlBlaster.util.dispatch.DeliveryConnection.send(DeliveryConnection.java:195)
        at org.xmlBlaster.util.dispatch.DeliveryConnectionsHandler.send(DeliveryConnectionsHandler.java:356)
        at org.xmlBlaster.util.dispatch.DeliveryWorker.run(DeliveryWorker.java:76)
        at org.xmlBlaster.util.dispatch.DeliveryManager.putPre(DeliveryManager.java:444)
        at org.xmlBlaster.util.dispatch.DeliveryManager.putPre(DeliveryManager.java:423)
        at org.xmlBlaster.util.queue.ram.RamQueuePlugin.put(RamQueuePlugin.java:642)
        at org.xmlBlaster.client.XmlBlasterAccess.queueMessage(XmlBlasterAccess.java:523)
        at org.xmlBlaster.client.XmlBlasterAccess.publish(XmlBlasterAccess.java:666)
        at org.xmlBlaster.engine.cluster.ClusterManager.forwardPublish(ClusterManager.java:389)
        at org.xmlBlaster.engine.RequestBroker.publish(RequestBroker.java:1497)
        at org.xmlBlaster.engine.RequestBroker.publish(RequestBroker.java:1372)
        at org.xmlBlaster.engine.RequestBroker.publish(RequestBroker.java:1366)
        at org.xmlBlaster.engine.XmlBlasterImpl.publishArr(XmlBlasterImpl.java:205)
        at org.xmlBlaster.engine.XmlBlasterImpl.publishOneway(XmlBlasterImpl.java:229)
        at org.xmlBlaster.protocol.corba.ServerImpl.publishOneway(ServerImpl.java:167)
        at org.xmlBlaster.protocol.corba.serverIdl.ServerPOATie.publishOneway(ServerPOATie.java:48)
        at org.xmlBlaster.protocol.corba.serverIdl.ServerPOA._invoke(ServerPOA.java:65)
        at org.jacorb.poa.RequestProcessor.invokeOperation(RequestProcessor.java:247)
        at org.jacorb.poa.RequestProcessor.process(RequestProcessor.java:496)
        at org.jacorb.poa.RequestProcessor.run(RequestProcessor.java:635)
[May 19, 2003 3:45:26 PM TRACE RequestBroker-/node/djmproxy_xxx.xxx.xxx.xxx] Throwing execption in publish: 
 <exception errorCode='user.notConnected'>
  <class>org.xmlBlaster.util.XmlBlasterException</class>
  <node>psq_xxx.xxx.xxx.xxx</node>
  <location>XmlBlasterAccess</location>
  <lang>en</lang>
  <message><![CDATA[Your operation is not possible, please login with connect() first]]></message>
  <versionInfo>version=0.847,os.name=Linux,os.version=2.4.18-5,java.vm.vendor=Sun Microsystems Inc.,java.vm.version=1.4.1_01-b01,os.arch=i386,build.timestamp=05/15/2003 09:24 AM,build.java.vendor=Sun Microsystems Inc.,build.java.ve
rsion=1.4.1_01</versionInfo>
  <timestamp>2003-05-19 15:45:26.256</timestamp>
  <stackTrace><![CDATA[errorCode=user.notConnected message=Your operation is not possible, please login with connect() first
        at org.xmlBlaster.client.XmlBlasterAccess.publishOneway(XmlBlasterAccess.java:673)
        at com.bbn.quo.dpasa.quorum.PSQNativeClient.sendPubReply(PSQNativeClient.java:226)
        at com.bbn.quo.dpasa.quorum.PSQSecSession.intercept(PSQSecSession.java:332)
        at com.bbn.quo.dpasa.quorum.PSQSecSession.importMessage(PSQSecSession.java:249)
        at org.xmlBlaster.engine.XmlBlasterImpl.importAndAuthorize(XmlBlasterImpl.java:361)
        at org.xmlBlaster.engine.XmlBlasterImpl.publishArr(XmlBlasterImpl.java:204)
        at org.xmlBlaster.protocol.corba.ServerImpl.publishArr(ServerImpl.java:144)
        at org.xmlBlaster.protocol.corba.serverIdl.ServerPOATie.publishArr(ServerPOATie.java:63)
        at org.xmlBlaster.protocol.corba.serverIdl.ServerPOA._invoke(ServerPOA.java:96)
        at org.jacorb.poa.RequestProcessor.invokeOperation(RequestProcessor.java:247)
        at org.jacorb.poa.RequestProcessor.process(RequestProcessor.java:496)
        at org.jacorb.poa.RequestProcessor.run(RequestProcessor.java:635)]]></stackTrace>
  <embeddedMessage><![CDATA[]]></embeddedMessage>
 </exception>
[May 19, 2003 3:45:26 PM ERROR XmlBlasterImpl-/node/djmproxy_xxx.xxx.xxx.xxx] Caught exception on publish which can't be delivered to client because of 'oneway' mode: XmlBlasterException errorCode=[user.notConnected] node=[psq_xxx.xxx.xxx.xxx] location=[XmlBlasterAccess] message=[Your operation is not possible, please login with connect() first : ]

-- 
matighet at bbn.com   BBN Technologies