Extend AsyncResponseInvoker to be Generic to cope with binding-specific response address information - under TUSCANY-3807

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1051463 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 8 insertions, 5 deletions

diff --git a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/invocation/AsyncResponseInvoker.java b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/invocation/AsyncResponseInvoker.java
index fd07911084..0a28bed480 100644
--- a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/invocation/AsyncResponseInvoker.java
+++ b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/invocation/AsyncResponseInvoker.java
@@ -31,8 +31,11 @@ import org.apache.tuscany.sca.runtime.RuntimeEndpointReference;
  * A class that wraps the mechanics for sending async responses

  * and hides the decision about whether the response will be processed

  * natively or non-natively

+ * 

+ * This class is generic, based on the type of targetAddress information required by

+ * the Binding that creates it

  */

-public class AsyncResponseInvoker implements InvokerAsyncResponse, Serializable {

+public class AsyncResponseInvoker<T> implements InvokerAsyncResponse, Serializable {

     

     /**

 	 * 

@@ -41,12 +44,12 @@ public class AsyncResponseInvoker implements InvokerAsyncResponse, Serializable
 	

 	RuntimeEndpoint requestEndpoint;

     RuntimeEndpointReference responseEndpointReference; 

-    String responseTargetAddress;

+    T responseTargetAddress;

     String relatesToMsgID;

     

     public AsyncResponseInvoker(RuntimeEndpoint requestEndpoint,

 			RuntimeEndpointReference responseEndpointReference,

-			String responseTargetAddress, String relatesToMsgID) {

+			T responseTargetAddress, String relatesToMsgID) {

 		super();

 		this.requestEndpoint = requestEndpoint;

 		this.responseEndpointReference = responseEndpointReference;

@@ -69,11 +72,11 @@ public class AsyncResponseInvoker implements InvokerAsyncResponse, Serializable
         }

     } // end method invokeAsyncReponse(Message)

     

-    public String getResponseTargetAddress() {

+    public T getResponseTargetAddress() {

 		return responseTargetAddress;

 	}

 

-	public void setResponseTargetAddress(String responseTargetAddress) {

+	public void setResponseTargetAddress(T responseTargetAddress) {

 		this.responseTargetAddress = responseTargetAddress;

 	}