You are viewing a plain text version of this content. The canonical link for it is here.
Posted to s4-commits@incubator.apache.org by mm...@apache.org on 2012/01/03 11:19:16 UTC
[42/50] [abbrv] git commit: Survive when default ClientStub throws an
exception
Survive when default ClientStub throws an exception
Project: http://git-wip-us.apache.org/repos/asf/incubator-s4/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-s4/commit/25c0c615
Tree: http://git-wip-us.apache.org/repos/asf/incubator-s4/tree/25c0c615
Diff: http://git-wip-us.apache.org/repos/asf/incubator-s4/diff/25c0c615
Branch: refs/heads/dev
Commit: 25c0c61518bd645f802cfb225b4a5ae878c5b3cf
Parents: 00d3419
Author: Bruce Robbins <ro...@thosespent.corp.yahoo.com>
Authored: Thu Nov 17 21:47:46 2011 -0800
Committer: Bruce Robbins <ro...@thosespent.corp.yahoo.com>
Committed: Thu Nov 17 21:47:46 2011 -0800
----------------------------------------------------------------------
s4-core/src/main/java/io/s4/client/ClientStub.java | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/25c0c615/s4-core/src/main/java/io/s4/client/ClientStub.java
----------------------------------------------------------------------
diff --git a/s4-core/src/main/java/io/s4/client/ClientStub.java b/s4-core/src/main/java/io/s4/client/ClientStub.java
index a307e3b..65b9804 100644
--- a/s4-core/src/main/java/io/s4/client/ClientStub.java
+++ b/s4-core/src/main/java/io/s4/client/ClientStub.java
@@ -294,7 +294,7 @@ public abstract class ClientStub implements OutputStub, InputStub {
if (c != null && c.good() && c.clientReadMode.takePrivate()) {
try {
byte[] b = bytesFromEventWrapper(event);
- c.io.send(b);
+ if (b != null) c.io.send(b);
} catch (IOException e) {
logger.error("error sending response to client "