}
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