diff options
Diffstat (limited to 'sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java')
| -rw-r--r-- | sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java b/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java index 99eb30892e..ef8d1179a0 100644 --- a/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java +++ b/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java @@ -48,14 +48,11 @@ public class CometInvoker implements Invoker { Broadcaster broadcaster = CometComponentContext.broadcasters.get(sessionId); Message response = new MessageImpl(); if (broadcaster == null) { - System.out.println("Broadcaster already removed."); response.setBody(Status.CLIENT_DISCONNECTED); } else if (broadcaster.getAtmosphereResources().isEmpty()) { - System.out.println("Removing broadcaster " + sessionId + "..."); CometComponentContext.broadcasters.remove(sessionId); response.setBody(Status.CLIENT_DISCONNECTED); } else { - System.out.println("Using broadcaster " + sessionId + "..."); String callbackMethod = msg.getTo().getURI(); Object[] body = msg.getBody(); broadcaster.broadcast(callbackMethod + "($.secureEvalJSON('" + CometComponentContext.gson.toJson(body[0]) |