[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
>
>
>
>
>
>