summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java
diff options
context:
space:
mode:
authorantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-05-13 12:39:53 +0000
committerantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-05-13 12:39:53 +0000
commit9145d1479e838918317bc9d4c5e25fe537e5f6de (patch)
tree12c504c96900ee6ebeb19e71627cf3e97df4ab78 /branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java
parenta0d58fe9ff6b7babfa8fd076779fbd374fe1db19 (diff)
Abandon trying to use the new Axis2 JMS transport for now as its proving too messy tryingto backport it to the 1.4.1 release. Now trying a new approach which modifies the JMS transport from Axis2 1.4.1
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@774293 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java')
-rw-r--r--branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java109
1 files changed, 0 insertions, 109 deletions
diff --git a/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java b/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java
deleted file mode 100644
index 1016e88a82..0000000000
--- a/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/transport/base/SynchronousCallback.java
+++ /dev/null
@@ -1,109 +0,0 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.tuscany.sca.binding.ws.axis2.transport.base;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.context.OperationContext;
-import org.apache.axis2.description.AxisMessage;
-import org.apache.axis2.description.AxisOperation;
-import org.apache.axis2.wsdl.WSDLConstants;
-
-
-public class SynchronousCallback {
-
- private MessageContext outMessageContext;
- private MessageContext inMessageContext;
-
- private boolean isComplete;
-
- public SynchronousCallback(MessageContext outMessageContext) {
- this.outMessageContext = outMessageContext;
- this.isComplete = false;
- }
-
- public synchronized void setInMessageContext(MessageContext inMessageContext) throws AxisFault {
-
- // if some other thread has access and complete then return without doing any thing.
- // thread should have activate by the first message.
- if (!isComplete) {
- // this code is invoked only if the code use with axis2 at the client side
- // when axis2 client receive messages it waits in the sending thread until the response comes.
- // so this thread only notify the waiting thread and hence we need to build the message here.
- inMessageContext.getEnvelope().build();
- OperationContext operationContext = outMessageContext.getOperationContext();
- MessageContext msgCtx =
- operationContext.getMessageContext(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
-
- if (msgCtx == null) {
- // try to see whether there is a piggy back message context
- if (outMessageContext.getProperty(org.apache.axis2.Constants.PIGGYBACK_MESSAGE) != null) {
-
- msgCtx = (MessageContext) outMessageContext.getProperty(org.apache.axis2.Constants.PIGGYBACK_MESSAGE);
- msgCtx.setTransportIn(inMessageContext.getTransportIn());
- msgCtx.setTransportOut(inMessageContext.getTransportOut());
- msgCtx.setServerSide(false);
- msgCtx.setProperty(BaseConstants.MAIL_CONTENT_TYPE,
- inMessageContext.getProperty(BaseConstants.MAIL_CONTENT_TYPE));
- // FIXME: this class must not be transport dependent since it is used by AbstractTransportListener
- msgCtx.setIncomingTransportName(org.apache.axis2.Constants.TRANSPORT_MAIL);
- msgCtx.setEnvelope(inMessageContext.getEnvelope());
-
- } else {
- inMessageContext.setOperationContext(operationContext);
- inMessageContext.setServiceContext(outMessageContext.getServiceContext());
- if (!operationContext.isComplete()) {
- operationContext.addMessageContext(inMessageContext);
- }
- AxisOperation axisOp = operationContext.getAxisOperation();
- AxisMessage inMessage = axisOp.getMessage(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
- inMessageContext.setAxisMessage(inMessage);
- inMessageContext.setServerSide(false);
- }
-
- } else {
- msgCtx.setOperationContext(operationContext);
- msgCtx.setServiceContext(outMessageContext.getServiceContext());
- AxisOperation axisOp = operationContext.getAxisOperation();
- AxisMessage inMessage = axisOp.getMessage(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
- msgCtx.setAxisMessage(inMessage);
- msgCtx.setTransportIn(inMessageContext.getTransportIn());
- msgCtx.setTransportOut(inMessageContext.getTransportOut());
- msgCtx.setServerSide(false);
- msgCtx.setProperty(BaseConstants.MAIL_CONTENT_TYPE,
- inMessageContext.getProperty(BaseConstants.MAIL_CONTENT_TYPE));
- // FIXME: this class must not be transport dependent since it is used by AbstractTransportListener
- msgCtx.setIncomingTransportName(org.apache.axis2.Constants.TRANSPORT_MAIL);
- msgCtx.setEnvelope(inMessageContext.getEnvelope());
-
- }
- this.inMessageContext = inMessageContext;
- isComplete = true;
- this.notifyAll();
- }
-
- }
-
-
- public boolean isComplete() {
- return isComplete;
- }
-
- public void setComplete(boolean complete) {
- isComplete = complete;
- }
-
-}