[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[xmlblaster] Client never leaves the function XmlblasterAccess.connect
Hi,
I encountered a strange problem last day.
I have some clients connected to my Xmlblaster server.
I stopped the Xmlblaster server and I restarted it later.
One of my client did not reconnect to the Xmlblaster server.
My clients are not configured in client fail safe mode. When a client
detects that the connection is dead,
it closes the connection and open a new one.
After some debug I can see that my thread connector was blocked to the
function XmlblasterAccess.connect.
##### code #####
if (this.clientQueue.getNumOfEntries() > 0) {
long num = this.clientQueue.getNumOfEntries();
log.info(getLogId()+"We have " + num + " client side queued
tail back messages");
this.dispatchManager.switchToASyncMode();
while (this.clientQueue.getNumOfEntries() > 0) {
try { Thread.sleep(20L); } catch( InterruptedException i)
{}
}
log.info((num-this.clientQueue.getNumOfEntries()) + " client
side queued tail back messages sent");
this.dispatchManager.switchToSyncMode();
}
##### end code #####
The field clientQueue contains 6 entries (Essentially subscribe) and
they are never cleaned. That's why the code
##### code #####
while (this.clientQueue.getNumOfEntries() > 0) {
try { Thread.sleep(20L); } catch( InterruptedException i)
{}
}
##### end code #####
Never finished.
Further more, the field dispatchManager has the attribute isShutDown set
to true...
So my question is How can I avoid this issue ?
Thanks,
Xavier.