svn commit: r719430 - in /ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2: OComm.java OEventHandler.java OInvoke.java OPickReceive.java

[mriou]

Author: mriou
Date: Thu Nov 20 15:59:56 2008
New Revision: 719430

URL: http://svn.apache.org/viewvc?rev=719430&view=rev
Log:
Resourceful event handler.

Added:
    
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OComm.java
Modified:
    
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OEventHandler.java
    
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OInvoke.java
    
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OPickReceive.java

Added: 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OComm.java
URL: 
http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OComm.java?rev=719430&view=auto
==============================================================================
--- 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OComm.java
 (added)
+++ 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OComm.java
 Thu Nov 20 15:59:56 2008
@@ -0,0 +1,12 @@
+package org.apache.ode.bpel.rtrep.v2;
+
+import javax.wsdl.Operation;
+
+public interface OComm {
+
+    OPartnerLink getPartnerLink();
+    Operation getOperation();
+    OResource getResource();
+
+    boolean isRestful();
+}

Modified: 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OEventHandler.java
URL: 
http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OEventHandler.java?rev=719430&r1=719429&r2=719430&view=diff
==============================================================================
--- 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OEventHandler.java
 (original)
+++ 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OEventHandler.java
 Thu Nov 20 15:59:56 2008
@@ -49,7 +49,7 @@
         }
     }
     
-    public static class OEvent extends OScope {
+    public static class OEvent extends OScope implements OComm {
         static final long serialVersionUID = -1L  ;
         
         /** Correlations to initialize. */
@@ -58,6 +58,7 @@
         /** Correlation set to match on. */
         public OScope.CorrelationSet matchCorrelation;
 
+        public OResource resource;
         public OPartnerLink partnerLink;
         public Operation operation;
         public OScope.Variable variable;
@@ -65,7 +66,6 @@
         /** OASIS addition for disambiguating receives (optional). */
         public String messageExchangeId = "";
 
-
         public String getCorrelatorId() {
             return partnerLink.getId() + "." + operation.getName();
         }
@@ -73,5 +73,22 @@
         public OEvent(OProcess owner, OActivity parent) {
             super(owner, parent);
         }
+
+        public Operation getOperation() {
+            return operation;
+        }
+
+        public OPartnerLink getPartnerLink() {
+            return partnerLink;
+        }
+
+        public OResource getResource() {
+            return resource;
+        }
+
+        public boolean isRestful() {
+            return partnerLink == null && resource != null;
+        }
+
     }
 }

Modified: 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OInvoke.java
URL: 
http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OInvoke.java?rev=719430&r1=719429&r2=719430&view=diff
==============================================================================
--- 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OInvoke.java
 (original)
+++ 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OInvoke.java
 Thu Nov 20 15:59:56 2008
@@ -26,7 +26,7 @@
 /**
  * Compiled rerpresentation of the BPEL <code>&lt;invoke&gt;</code> activity.
  */
-public class OInvoke extends OActivity {
+public class OInvoke extends OActivity implements OComm {
   
     static final long serialVersionUID = -1L  ;
     public OPartnerLink partnerLink;
@@ -49,4 +49,20 @@
     public OInvoke(OProcess owner, OActivity parent) {
         super(owner, parent);
     }
+
+    public OPartnerLink getPartnerLink() {
+        return partnerLink;
+    }
+
+    public Operation getOperation() {
+        return operation;
+    }
+
+    public OResource getResource() {
+        return null;
+    }
+    public boolean isRestful() {
+        return false;
+    }
+
 }

Modified: 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OPickReceive.java
URL: 
http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OPickReceive.java?rev=719430&r1=719429&r2=719430&view=diff
==============================================================================
--- 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OPickReceive.java
 (original)
+++ 
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OPickReceive.java
 Thu Nov 20 15:59:56 2008
@@ -52,7 +52,7 @@
         }
     }
     
-    public static class OnMessage extends OBase {
+    public static class OnMessage extends OBase implements OComm {
       
         static final long serialVersionUID = -1L  ;
         
@@ -82,5 +82,17 @@
         public boolean isRestful() {
             return partnerLink == null && resource != null;
         }
+
+        public OPartnerLink getPartnerLink() {
+            return partnerLink;
+        }
+
+        public Operation getOperation() {
+            return operation;
+        }
+
+        public OResource getResource() {
+            return resource;
+        }
     }
 }