private IClientChannelSink _nextChannelSink;\r
private SoapCore _soapCore = SoapCore.DefaultInstance;\r
\r
- public SoapClientFormatterSink (IClientChannelSink sink)\r
+ public SoapClientFormatterSink (IClientChannelSink nextSink)\r
{\r
- _nextChannelSink = sink;\r
+ _nextChannelSink = nextSink;\r
}\r
\r
- internal SoapCore SoapCore\r
- {\r
+ internal SoapCore SoapCore {\r
get { return _soapCore; }\r
set { _soapCore = value; }\r
}\r
\r
// IClientChannelSink\r
- public IClientChannelSink NextChannelSink\r
- {\r
+ public IClientChannelSink NextChannelSink {\r
get {\r
return _nextChannelSink;\r
}\r
}\r
\r
// IMessageSink\r
- public IMessageSink NextSink\r
- {\r
+ public IMessageSink NextSink {\r
get {\r
return null ;\r
}\r
}\r
\r
// IChannelSinkBase\r
- public IDictionary Properties\r
- {\r
+ public IDictionary Properties {\r
get {\r
return null;\r
}\r
ITransportHeaders requestHeaders;\r
SoapMessageFormatter soapMsgFormatter;\r
\r
- SerializeMessage(msg, out requestStream, out requestHeaders, out soapMsgFormatter);\r
+ SerializeMessage (msg, out requestStream, out requestHeaders,\r
+ out soapMsgFormatter);\r
\r
- ClientChannelSinkStack stack = new ClientChannelSinkStack(replySink);\r
+ ClientChannelSinkStack stack = new ClientChannelSinkStack (replySink);\r
stack.Push(this, new CallData (msg, soapMsgFormatter));\r
\r
- _nextChannelSink.AsyncProcessRequest(stack, msg, requestHeaders, requestStream);\r
+ _nextChannelSink.AsyncProcessRequest (stack, msg, requestHeaders, requestStream);\r
\r
return null;\r
}\r
ITransportHeaders headers,\r
Stream stream)\r
{\r
- CallData data = (CallData)state;\r
+ CallData data = (CallData) state;\r
SoapMessageFormatter soapMsgFormatter = data.Formatter;\r
- IMessage replyMessage = (IMessage) DeserializeMessage(stream, headers, (IMethodCallMessage)data.Msg, soapMsgFormatter);\r
- sinkStack.DispatchReplyMessage(replyMessage);\r
+ IMessage replyMessage = (IMessage) DeserializeMessage (\r
+ stream, headers, (IMethodCallMessage) data.Msg,\r
+ soapMsgFormatter);\r
+ sinkStack.DispatchReplyMessage (replyMessage);\r
\r
}\r
\r
Stream requestStream, responseStream;\r
ITransportHeaders requestHeaders, responseHeaders;\r
SoapMessageFormatter soapMsgFormatter;\r
- \r
- SerializeMessage(msg, out requestStream, out requestHeaders, out soapMsgFormatter);\r
- _nextChannelSink.ProcessMessage(msg, requestHeaders, requestStream, out responseHeaders, out responseStream);\r
\r
- return DeserializeMessage(responseStream, responseHeaders, (IMethodCallMessage)msg, soapMsgFormatter);\r
+ SerializeMessage (msg, out requestStream, out requestHeaders,\r
+ out soapMsgFormatter);\r
+ _nextChannelSink.ProcessMessage(msg, requestHeaders,\r
+ requestStream, out responseHeaders,\r
+ out responseStream);\r
+\r
+ return DeserializeMessage(responseStream, responseHeaders,\r
+ (IMethodCallMessage) msg, soapMsgFormatter);\r
}\r
\r
\r
private void SerializeMessage(IMessage msg, out Stream requestStream, out ITransportHeaders requestHeaders, out SoapMessageFormatter soapMsgFormatter) {\r
SoapMessage soapMsg;\r
soapMsgFormatter = new SoapMessageFormatter();\r
- soapMsg = soapMsgFormatter.BuildSoapMessageFromMethodCall((IMethodCallMessage) msg, out requestHeaders);\r
- \r
+ soapMsg = soapMsgFormatter.BuildSoapMessageFromMethodCall (\r
+ (IMethodCallMessage) msg, out requestHeaders);\r
+\r
// Get the stream where the message will be serialized\r
- requestStream = _nextChannelSink.GetRequestStream(msg, requestHeaders);\r
- \r
- if(requestStream == null) requestStream = new MemoryStream();\r
- \r
+ requestStream = _nextChannelSink.GetRequestStream (msg,\r
+ requestHeaders);\r
+\r
+ if (requestStream == null)\r
+ requestStream = new MemoryStream();\r
+\r
// Serialize the message into the stream\r
_soapCore.Serializer.Serialize(requestStream, soapMsg, null);\r
- \r
- if(requestStream is MemoryStream){\r
+\r
+ if (requestStream is MemoryStream)\r
requestStream.Position = 0;\r
- }\r
}\r
\r
\r
fm.TopObject = rtnMessage;\r
object objReturn = fm.Deserialize(responseStream);\r
\r
- if (objReturn is SoapFault) \r
+ if (objReturn is SoapFault)\r
return soapMsgFormatter.FormatFault ((SoapFault) objReturn, mcm);\r
else\r
return soapMsgFormatter.FormatResponse ((ISoapMessage) objReturn, mcm);\r
\r
class CallData\r
{\r
- public CallData (IMessage msg, SoapMessageFormatter formatter) { Msg = msg; Formatter = formatter; }\r
+ public CallData (IMessage msg, SoapMessageFormatter formatter)\r
+ {\r
+ Msg = msg;\r
+ Formatter = formatter;\r
+ }\r
+\r
public IMessage Msg;\r
public SoapMessageFormatter Formatter;\r
}\r