Author: slaws
Date: Wed Nov 24 12:03:57 2010
New Revision: 1038575
URL: http://svn.apache.org/viewvc?rev=1038575&view=rev
Log:
TUSCANY-3786 - add an operation so that the EPR can indicate whether it will do
an async invocation or not.
Modified:
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/EndpointReference.java
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/impl/EndpointReferenceImpl.java
Modified:
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/EndpointReference.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/EndpointReference.java?rev=1038575&r1=1038574&r2=1038575&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/EndpointReference.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/EndpointReference.java
Wed Nov 24 12:03:57 2010
@@ -162,4 +162,13 @@ public interface EndpointReference exten
* @param status the new status
*/
void setStatus(Status status);
+
+ /**
+ * When true this endpoint reference is able to process the invocation
+ * as being asynchronous. The forward call is effectively one-way
+ * and the response will arrive asynchronously via the CallbackEndpoint
+ *
+ * @return true if the reference is asynchronous
+ */
+ boolean isAsyncInvocation();
}
Modified:
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/impl/EndpointReferenceImpl.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/impl/EndpointReferenceImpl.java?rev=1038575&r1=1038574&r2=1038575&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/impl/EndpointReferenceImpl.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/assembly/src/main/java/org/apache/tuscany/sca/assembly/impl/EndpointReferenceImpl.java
Wed Nov 24 12:03:57 2010
@@ -230,4 +230,13 @@ public class EndpointReferenceImpl imple
public void setStatus(Status status) {
this.status = status;
}
+
+ public boolean isAsyncInvocation() {
+ for(Intent intent : getRequiredIntents()){
+ if (intent.getName().getLocalPart().equals("asyncInvocation")){
+ return true;
+ }
+ }
+ return false;
+ }
}