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

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

Michael Atighetchi wrote:

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.

Yes, currently you still have to connect, it will be a remote connection even if you run
in the same JVM.
The native access support is currently one of my highest priorities (besides 3 other issues)
as i need this in another case as well.

Marcel


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