diff options
Diffstat (limited to 'java/src/IceInternal/BatchOutgoing.java')
-rw-r--r-- | java/src/IceInternal/BatchOutgoing.java | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/java/src/IceInternal/BatchOutgoing.java b/java/src/IceInternal/BatchOutgoing.java index 1e0071f047a..eecd4cb692a 100644 --- a/java/src/IceInternal/BatchOutgoing.java +++ b/java/src/IceInternal/BatchOutgoing.java @@ -34,23 +34,25 @@ public final class BatchOutgoing implements OutgoingMessageCallback if(_handler != null && !_handler.flushBatchRequests(this) || _connection != null && !_connection.flushBatchRequests(this)) - synchronized(this) { - while(_exception == null && !_sent) + synchronized(this) { - try + while(_exception == null && !_sent) { - wait(); + try + { + wait(); + } + catch(java.lang.InterruptedException ex) + { + } } - catch(java.lang.InterruptedException ex) + + if(_exception != null) { + throw _exception; } } - - if(_exception != null) - { - throw _exception; - } } } |