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

RE: [xmlblaster] Failsafe Socket MODE



Hi Marcel,

Many Thanks for your quick Answer.

I added the line

ConnectQos qos = new ConnectQos(glob,"test/10","secret"); 

To helloword6.java and it does not work :(


How do I use this file ?

 1) I stop xmlblaster ==> It's no more possible to connect to xmlblaster.
 2) I launch the example ==> 
	I expect that there is no error(s) during subscription etc...
	And that the client switches to the Polling state.
	If I use the line 
		glob.getProperty().set("protocol","IOR");		
	All is ok.

	But with glob.getProperty().set("protocol","SOCKET");
	it does not work, it switches to the dead state and not to the
polling state :(

	[Apr 8, 2003 3:07:01 PM WARN
DeliveryConnection-client:client/test/10] Connection transition DEAD -> DEAD
for 	client:client/test/10: We ignore it. [Apr 8, 2003 3:07:01 PM ERROR
HelloWorld6] Houston, we have a problem: errorC
ode=communication.noConnection.dead message=Initializing of plugin SOCKET
failed:XmlBlasterException errorCode=[commu	nication.noConnection]
node=[xmlBlaster] location=[SocketConnection] message=[Socket client
connection to XRO on port 	7607 failed, try options '-socket.hostname
<ip> -socket.port <port>' and check if the xmlBlaster server has loaded the
socket driver in xmlBlaster.properties : java.net.ConnectException:
Connection refused: connect] : Original 

Best Regards,

Xavier.

-----Original Message-----
From: Marcel Ruff [mailto:mr at marcelruff.info] 
Sent: Tuesday, April 08, 2003 10:06 AM
To: xmlblaster at server.xmlblaster.org
Subject: Re: [xmlblaster] Failsafe Socket MODE


Xavier Roques wrote:
> Hi,
> 
> The following lines does not work :((
> 
>     	try {
>       	  glob.getProperty().set("protocol","SOCKET");
Hi Xavier,

adding this line

   this.glob.getProperty().set("protocol","SOCKET");

to HelloWorld3.java and HelloWorld6.java works fine here.

What are the errors you have?

best regards

Marcel


> 	    }	
> 
>         con = glob.getXmlBlasterAccess(); // Find orb
> 
>          String passwd = "secret";
>          ConnectQos connectQos = new ConnectQos(glob, 
> senderName+"/10", passwd);
> 	//Here the public session id is equal to 10 to allow the fail safe 
> mode even if
> 	//xmlblaster is not found.		
> 	// == "<qos>...</qos>";
> 
>          // Setup fail save handling ...
>          Address addressProp = new Address(glob);
>          addressProp.setDelay(reconnectDelay); // retry connecting 
> every 2 sec
>          addressProp.setRetries(-1);       // -1 == forever
>          addressProp.setPingInterval(-1L); // switched off
>          con.registerConnectionListener(this);
> 
>          connectQos.setAddress(addressProp);
> 
>          // and do the login ...
>          con.connect(connectQos, this);  // Login to xmlBlaster, 
> register for updates
>          serverThread = EmbeddedXmlBlaster.startXmlBlaster(glob);
>       }
>       catch (XmlBlasterException e) {
>           log.warn(ME, "setUp() - login failed"); // should not happen
>           fail("setUp() - login faile");
>       }
> 
> If I update the line 
> 	glob.getProperty().set("protocol","SOCKET");
> By 
> 	glob.getProperty().set("protocol","IOR");
> 
> All is ok. Is it a bug ?
> 
> Xavier
> 
> 
> 
> 	
> 
>