Return-Path: X-Original-To: apmail-tuscany-commits-archive@www.apache.org Delivered-To: apmail-tuscany-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D810C4114 for ; Wed, 25 May 2011 23:09:53 +0000 (UTC) Received: (qmail 83961 invoked by uid 500); 25 May 2011 23:09:53 -0000 Delivered-To: apmail-tuscany-commits-archive@tuscany.apache.org Received: (qmail 83920 invoked by uid 500); 25 May 2011 23:09:53 -0000 Mailing-List: contact commits-help@tuscany.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@tuscany.apache.org Delivered-To: mailing list commits@tuscany.apache.org Received: (qmail 83912 invoked by uid 99); 25 May 2011 23:09:53 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 25 May 2011 23:09:53 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 25 May 2011 23:09:52 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 423FB2388906; Wed, 25 May 2011 23:09:32 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1127718 - in /tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime: CometInvoker.java handler/CometBindingHandler.java Date: Wed, 25 May 2011 23:09:32 -0000 To: commits@tuscany.apache.org From: fmoga@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20110525230932.423FB2388906@eris.apache.org> Author: fmoga Date: Wed May 25 23:09:31 2011 New Revision: 1127718 URL: http://svn.apache.org/viewvc?rev=1127718&view=rev Log: Cleanup binding code by removing debug prints. Modified: tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java Modified: tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java?rev=1127718&r1=1127717&r2=1127718&view=diff ============================================================================== --- tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java (original) +++ tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometInvoker.java Wed May 25 23:09:31 2011 @@ -48,14 +48,11 @@ public class CometInvoker implements Inv 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]) Modified: tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java?rev=1127718&r1=1127717&r2=1127718&view=diff ============================================================================== --- tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java (original) +++ tuscany/sca-java-2.x/trunk/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java Wed May 25 23:09:31 2011 @@ -97,7 +97,7 @@ public class CometBindingHandler { @GET @Path("/connect") public SuspendResponse connect() { - System.out.println("-- connect -- Session Id: " + request.getSession().getId()); +// System.out.println("-- connect -- Session Id: " + request.getSession().getId()); if (broadcaster == null) { broadcaster = new JerseyBroadcaster(); // broadcaster.setBroadcasterLifeCyclePolicy(new Builder().policy(ATMOSPHERE_RESOURCE_POLICY.IDLE_DESTROY) @@ -130,14 +130,13 @@ public class CometBindingHandler { public void handleRequest(@PathParam("service") final String service, @PathParam("method") final String method, @FormParam("callbackMethod") final String callbackMethod, @FormParam("params") final String jsonData) throws InvocationTargetException { - System.out.println("-- handleRequest -- Session Id: " + request.getSession().getId()); +// System.out.println("-- handleRequest -- Session Id: " + request.getSession().getId()); final String url = "/" + service + "/" + method; final RuntimeEndpoint wire = context.getEndpoint(url); final Operation operation = context.getOperation(url); final Object[] args = decodeJsonDataForOperation(jsonData, operation); Message msg = createMessageWithMockedCometReference(args, callbackMethod); - System.out.println("CometBindingHandler thread id: " + Thread.currentThread().getId()); wire.invoke(operation, msg); }