Author: veithen Date: Tue Dec 20 20:50:43 2011 New Revision: 1221487 URL: http://svn.apache.org/viewvc?rev=1221487&view=rev Log: Make TestCallback thread safe.
Modified: axis/axis2/java/sandesha/trunk/modules/tests/src/test/java/org/apache/sandesha2/SandeshaTestCase.java Modified: axis/axis2/java/sandesha/trunk/modules/tests/src/test/java/org/apache/sandesha2/SandeshaTestCase.java URL: http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/tests/src/test/java/org/apache/sandesha2/SandeshaTestCase.java?rev=1221487&r1=1221486&r2=1221487&view=diff ============================================================================== --- axis/axis2/java/sandesha/trunk/modules/tests/src/test/java/org/apache/sandesha2/SandeshaTestCase.java (original) +++ axis/axis2/java/sandesha/trunk/modules/tests/src/test/java/org/apache/sandesha2/SandeshaTestCase.java Tue Dec 20 20:50:43 2011 @@ -220,15 +220,15 @@ public class SandeshaTestCase extends Te boolean errorReported = false; String resultStr; - public boolean isComplete() { + public synchronized boolean isComplete() { return completed; } - public boolean isErrorReported() { + public synchronized boolean isErrorReported() { return errorReported; } - public String getResult () { + public synchronized String getResult () { return resultStr; } @@ -236,23 +236,23 @@ public class SandeshaTestCase extends Te this.name = name; } - public void onComplete() { + public synchronized void onComplete() { completed = true; } - public void onMessage(MessageContext result) { + public synchronized void onMessage(MessageContext result) { SOAPBody body = result.getEnvelope().getBody(); OMElement contents = body.getFirstElement(); this.resultStr = checkEchoOMBlock(contents); System.out.println("TestCallback got text: '" + resultStr + "'"); } - public void onFault(MessageContext result) { + public synchronized void onFault(MessageContext result) { errorReported = true; System.out.println("TestCallback got fault: " + result.getEnvelope()); } - public void onError (Exception e) { + public synchronized void onError (Exception e) { errorReported = true; System.out.println("TestCallback got exception"); e.printStackTrace();