[jboss-svn-commits] JBL Code SVN: r29600 - labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers.

[jboss-svn-commits at lists.jboss.org]

Author: mark.proctor at jboss.com
Date: 2009-10-13 21:22:47 -0400 (Tue, 13 Oct 2009)
New Revision: 29600

Modified:
   labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBaseResponseHandler.java
   labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBlockingResponseHandler.java
   labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/BlockingMessageResponseHandler.java
Log:
JBRULES-2269 Virtual Service Manager
-now works for xstream
-split into remote/local

Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBaseResponseHandler.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBaseResponseHandler.java	2009-10-14 01:21:57 UTC (rev 29599)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBaseResponseHandler.java	2009-10-14 01:22:47 UTC (rev 29600)
@@ -1,9 +1,9 @@
 package org.drools.vsm.responsehandlers;
 
-import org.drools.vsm.BaseMinaHandler;
-
 import java.lang.reflect.Constructor;
 
+import org.drools.vsm.MessageResponseHandler;
+
 /**
  * Abstract base class for client ResponseHandlers. Provides synchonized access to <field>done</field> which represents
  * if the response is completed. Also has an <field>error</field> which will be set when there is a problem with
@@ -15,7 +15,9 @@
  *
  * @author <a href="mailto:stampy88 at yahoo.com">dave sinclair</a>
  */
-public abstract class AbstractBaseResponseHandler implements BaseMinaHandler.ResponseHandler {
+public abstract class AbstractBaseResponseHandler
+    implements
+    MessageResponseHandler {
     private volatile boolean done;
     private RuntimeException error;
 
@@ -53,13 +55,13 @@
         RuntimeException clientSideException;
 
         try {
-            Constructor<? extends RuntimeException> constructor = serverSideException.getClass().getConstructor(String.class);
+            Constructor< ? extends RuntimeException> constructor = serverSideException.getClass().getConstructor( String.class );
 
-            clientSideException = constructor.newInstance(
-        		"Server-side Exception: " + serverSideException.getMessage());
-        } catch (Exception e) {
+            clientSideException = constructor.newInstance( "Server-side Exception: " + serverSideException.getMessage() );
+        } catch ( Exception e ) {
             // this should never happen - if it does, it is a programming error
-            throw new RuntimeException("Could not create client side exception", e);
+            throw new RuntimeException( "Could not create client side exception",
+                                        e );
         }
 
         return clientSideException;

Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBlockingResponseHandler.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBlockingResponseHandler.java	2009-10-14 01:21:57 UTC (rev 29599)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/AbstractBlockingResponseHandler.java	2009-10-14 01:22:47 UTC (rev 29600)
@@ -20,16 +20,16 @@
      */
     public synchronized boolean waitTillDone(long time) {
 
-        if (!isDone()) {
+        if ( !isDone() ) {
             try {
-                wait(time);
-            } catch (InterruptedException e) {
+                wait( time );
+            } catch ( InterruptedException e ) {
                 // swallow and return state of done
             }
         }
 
-        if(hasError()) {            
-            throw createSideException(getError());
+        if ( hasError() ) {
+            throw createSideException( getError() );
         }
 
         return isDone();

Modified: labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/BlockingMessageResponseHandler.java
===================================================================
--- labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/BlockingMessageResponseHandler.java	2009-10-14 01:21:57 UTC (rev 29599)
+++ labs/jbossrules/trunk/drools-vsm/src/main/java/org/drools/vsm/responsehandlers/BlockingMessageResponseHandler.java	2009-10-14 01:22:47 UTC (rev 29600)
@@ -4,26 +4,26 @@
 package org.drools.vsm.responsehandlers;
 
 import org.drools.vsm.Message;
-import org.drools.vsm.BaseMinaHandler.MessageResponseHandler;
+import org.drools.vsm.MessageResponseHandler;
 
-public class BlockingMessageResponseHandler extends AbstractBlockingResponseHandler implements MessageResponseHandler {
-    private static final int ATTACHMENT_ID_WAIT_TIME = 10000;
-    private static final int CONTENT_ID_WAIT_TIME = 3000;
+public class BlockingMessageResponseHandler extends AbstractBlockingResponseHandler
+    implements
+    MessageResponseHandler {
+    private static final int ATTACHMENT_ID_WAIT_TIME = 100000;
+    private static final int CONTENT_ID_WAIT_TIME    = 500000;
 
     private volatile Message message;
 
     public synchronized void receive(Message message) {
         this.message = message;
-        setDone(true);
+        setDone( true );
     }
 
-    public  Message getMessage() {
-        // note that this method doesn't need to be synced because if waitTillDone returns true,
-        // it means attachmentId is available
-        boolean done = waitTillDone(ATTACHMENT_ID_WAIT_TIME);
+    public Message getMessage() {
+        boolean done = waitTillDone( CONTENT_ID_WAIT_TIME );
 
-        if (!done) {
-            throw new RuntimeException("Timeout : unable to retrieve Object Id");
+        if ( !done ) {
+            throw new RuntimeException( "Timeout : unable to retrieve Object Id" );
         }
 
         return this.message;