blob: 1016e88a82c64bde5fbdc74065e3eaa0f6a96dba (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
* 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;
}
}
|
