Return-Path: Delivered-To: apmail-tuscany-commits-archive@www.apache.org Received: (qmail 94246 invoked from network); 3 Sep 2009 08:43:29 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 3 Sep 2009 08:43:29 -0000 Received: (qmail 67204 invoked by uid 500); 3 Sep 2009 08:43:29 -0000 Delivered-To: apmail-tuscany-commits-archive@tuscany.apache.org Received: (qmail 67156 invoked by uid 500); 3 Sep 2009 08:43:29 -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 67147 invoked by uid 99); 3 Sep 2009 08:43:29 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Sep 2009 08:43:29 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.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; Thu, 03 Sep 2009 08:43:27 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 45BB4238888F; Thu, 3 Sep 2009 08:43:07 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r810816 - in /tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src: main/java/composite/SourceImpl.java test/java/composite/CompositeTestCase.java Date: Thu, 03 Sep 2009 08:43:07 -0000 To: commits@tuscany.apache.org From: nash@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090903084307.45BB4238888F@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: nash Date: Thu Sep 3 08:43:06 2009 New Revision: 810816 URL: http://svn.apache.org/viewvc?rev=810816&view=rev Log: Update samples/implementation-composite to verify successful completion (TUSCANY-3253) Modified: tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/main/java/composite/SourceImpl.java tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/test/java/composite/CompositeTestCase.java Modified: tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/main/java/composite/SourceImpl.java URL: http://svn.apache.org/viewvc/tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/main/java/composite/SourceImpl.java?rev=810816&r1=810815&r2=810816&view=diff ============================================================================== --- tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/main/java/composite/SourceImpl.java (original) +++ tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/main/java/composite/SourceImpl.java Thu Sep 3 08:43:06 2009 @@ -27,6 +27,7 @@ @Scope("COMPOSITE") public class SourceImpl implements Source, SourceCallback { + public static int callbackCount = 0; private Target targetReference; private Target targetReference2; @@ -49,6 +50,9 @@ } public void receiveResult(String result) { + synchronized(this) { + callbackCount += 1; + } System.out.println("Work thread " + Thread.currentThread()); System.out.println("Result: " + result); } Modified: tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/test/java/composite/CompositeTestCase.java URL: http://svn.apache.org/viewvc/tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/test/java/composite/CompositeTestCase.java?rev=810816&r1=810815&r2=810816&view=diff ============================================================================== --- tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/test/java/composite/CompositeTestCase.java (original) +++ tuscany/branches/sca-java-1.5.1/samples/implementation-composite/src/test/java/composite/CompositeTestCase.java Thu Sep 3 08:43:06 2009 @@ -39,13 +39,12 @@ } public void test() throws Exception { - try { - System.out.println("Main thread " + Thread.currentThread()); - source.clientMethod("Client.main"); - System.out.println("Sleeping ..."); - Thread.sleep(1000); - } catch (Throwable t) { - t.printStackTrace(); + System.out.println("Main thread " + Thread.currentThread()); + source.clientMethod("Client.main"); + System.out.println("Sleeping ..."); + Thread.sleep(1000); + if (SourceImpl.callbackCount != 2) { + throw new IllegalStateException("Expected callbacks not received"); } } }