summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/CommunicatorBatchOutgoingAsync.java
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2012-10-26 11:04:37 +0200
committerBenoit Foucher <benoit@zeroc.com>2012-10-26 11:04:37 +0200
commit16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa (patch)
treeed1d3bf97e2c3210bdca93722d91a70a1c9ba7fe /java/src/IceInternal/CommunicatorBatchOutgoingAsync.java
parentRenamed MetricsAdmin facet name to Metrics (diff)
downloadice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.tar.bz2
ice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.tar.xz
ice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.zip
Fixed bug in communicator flush batch requests, also fixed C++ SSL issue where ice_connectionId wouldn't work
Diffstat (limited to 'java/src/IceInternal/CommunicatorBatchOutgoingAsync.java')
-rw-r--r--java/src/IceInternal/CommunicatorBatchOutgoingAsync.java14
1 files changed, 11 insertions, 3 deletions
diff --git a/java/src/IceInternal/CommunicatorBatchOutgoingAsync.java b/java/src/IceInternal/CommunicatorBatchOutgoingAsync.java
index 014d6e041e6..a2c9514ebdd 100644
--- a/java/src/IceInternal/CommunicatorBatchOutgoingAsync.java
+++ b/java/src/IceInternal/CommunicatorBatchOutgoingAsync.java
@@ -90,10 +90,18 @@ public class CommunicatorBatchOutgoingAsync extends Ice.AsyncResult
++_useCount;
}
- int status = con.flushAsyncBatchRequests(new BatchOutgoingAsyncI());
- if((status & AsyncStatus.Sent) > 0)
+ try
{
- _sentSynchronously = false;
+ int status = con.flushAsyncBatchRequests(new BatchOutgoingAsyncI());
+ if((status & AsyncStatus.Sent) > 0)
+ {
+ _sentSynchronously = false;
+ }
+ }
+ catch(Ice.LocalException ex)
+ {
+ check(false);
+ throw ex;
}
}