diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2012-04-24 13:48:09 +0200 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2012-04-24 13:48:09 +0200 |
| commit | bc7de3b1a7a6e06fb1e36794e129990a0219bfb9 (patch) | |
| tree | c4af38320f4869c30d7bd2911c41d3ed73b015ee /java/test/Ice/invoke/BlobjectAsyncI.java | |
| parent | Java port (diff) | |
| download | ice-bc7de3b1a7a6e06fb1e36794e129990a0219bfb9.tar.bz2 ice-bc7de3b1a7a6e06fb1e36794e129990a0219bfb9.tar.xz ice-bc7de3b1a7a6e06fb1e36794e129990a0219bfb9.zip | |
Java test and bug fixes
Diffstat (limited to 'java/test/Ice/invoke/BlobjectAsyncI.java')
| -rw-r--r-- | java/test/Ice/invoke/BlobjectAsyncI.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/java/test/Ice/invoke/BlobjectAsyncI.java b/java/test/Ice/invoke/BlobjectAsyncI.java index b11d5bfc4c3..4b8bdb48b98 100644 --- a/java/test/Ice/invoke/BlobjectAsyncI.java +++ b/java/test/Ice/invoke/BlobjectAsyncI.java @@ -18,7 +18,9 @@ public class BlobjectAsyncI extends Ice.BlobjectAsync { Ice.Communicator communicator = current.adapter.getCommunicator(); Ice.InputStream in = Ice.Util.createInputStream(communicator, inParams); + in.startEncapsulation(); Ice.OutputStream out = Ice.Util.createOutputStream(communicator); + out.startEncapsulation(); if(current.operation.equals("opOneway")) { cb.ice_response(true, new byte[0]); @@ -28,12 +30,14 @@ public class BlobjectAsyncI extends Ice.BlobjectAsync String s = in.readString(); out.writeString(s); out.writeString(s); + out.endEncapsulation(); cb.ice_response(true, out.finished()); } else if(current.operation.equals("opException")) { MyException ex = new MyException(); out.writeException(ex); + out.endEncapsulation(); cb.ice_response(false, out.finished()); } else if(current.operation.equals("shutdown")) @@ -52,6 +56,7 @@ public class BlobjectAsyncI extends Ice.BlobjectAsync { out.writeBool(false); } + out.endEncapsulation(); cb.ice_response(true, out.finished()); } else |