From 6ec76289c69654eb951edcb705fa899fb4e7d065 Mon Sep 17 00:00:00 2001
From: edwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68>
Date: Tue, 21 Dec 2010 11:36:36 +0000
Subject: 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
---
 .../tuscany/sca/core/invocation/AsyncResponseInvoker.java   | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

(limited to 'sca-java-2.x/trunk/modules/core/src/main')

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;
 	}
 
-- 
cgit v1.2.3