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@1051465 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 2 deletions

diff --git a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/wire/AsyncResponseDestinationInterceptor.java b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/wire/AsyncResponseDestinationInterceptor.java
index 7bb91f3081..43bf090796 100644
--- a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/wire/AsyncResponseDestinationInterceptor.java
+++ b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/wire/AsyncResponseDestinationInterceptor.java
@@ -105,7 +105,7 @@ public class AsyncResponseDestinationInterceptor extends InterceptorAsyncImpl {
             String msgID = (String)msg.getHeaders().get("MESSAGE_ID");
             
             // Create a response invoker and add it to the message headers
-            AsyncResponseInvoker respInvoker = new AsyncResponseInvoker(endpoint, null, asyncRespAddr, msgID);
+            AsyncResponseInvoker<String> respInvoker = new AsyncResponseInvoker<String>(endpoint, null, asyncRespAddr, msgID);
             msg.getHeaders().put("ASYNC_RESPONSE_INVOKER", respInvoker);
 
         } catch (JMSException e) {
@@ -130,7 +130,8 @@ public class AsyncResponseDestinationInterceptor extends InterceptorAsyncImpl {
 	 * @returns - the updated Tuscany message
 	 */
 	public Message processResponse(Message msg) {
-		AsyncResponseInvoker respInvoker = (AsyncResponseInvoker)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
+		@SuppressWarnings("unchecked")
+		AsyncResponseInvoker<String> respInvoker = (AsyncResponseInvoker<String>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
 		if ( respInvoker == null ) return msg;
 		
 		String responseAddress = respInvoker.getResponseTargetAddress();