diff options
| author | Mark Spruiell <mes@zeroc.com> | 2005-04-12 20:50:00 +0000 |
|---|---|---|
| committer | Mark Spruiell <mes@zeroc.com> | 2005-04-12 20:50:00 +0000 |
| commit | 3ac86ca67b43924dfddc0656f6d02b1d90f976b2 (patch) | |
| tree | 37eebd9827ccc98fde9877a3e4f09f6f163daa5d /java/src/IceInternal/Outgoing.java | |
| parent | fixing typo (diff) | |
| download | ice-3ac86ca67b43924dfddc0656f6d02b1d90f976b2.tar.bz2 ice-3ac86ca67b43924dfddc0656f6d02b1d90f976b2.tar.xz ice-3ac86ca67b43924dfddc0656f6d02b1d90f976b2.zip | |
fix for bug 218: Hang if oneways are not flushed
Diffstat (limited to 'java/src/IceInternal/Outgoing.java')
| -rw-r--r-- | java/src/IceInternal/Outgoing.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/java/src/IceInternal/Outgoing.java b/java/src/IceInternal/Outgoing.java index 6d31ef9a69f..9859932d4a4 100644 --- a/java/src/IceInternal/Outgoing.java +++ b/java/src/IceInternal/Outgoing.java @@ -14,6 +14,7 @@ public final class Outgoing public Outgoing(Ice.ConnectionI connection, Reference ref, String operation, Ice.OperationMode mode, java.util.Map context, boolean compress) + throws NonRepeatable { _connection = connection; _reference = ref; @@ -22,7 +23,14 @@ public final class Outgoing _os = new BasicStream(ref.getInstance()); _compress = compress; - writeHeader(operation, mode, context); + try + { + writeHeader(operation, mode, context); + } + catch(Ice.LocalException ex) + { + abort(ex); + } } // |