5 // Author: Atsushi Enomoto (atsushi@ximian.com)
7 // Copyright (C) 2009 Novell, Inc (http://www.novell.com)
9 // Permission is hereby granted, free of charge, to any person obtaining
10 // a copy of this software and associated documentation files (the
11 // "Software"), to deal in the Software without restriction, including
12 // without limitation the rights to use, copy, modify, merge, publish,
13 // distribute, sublicense, and/or sell copies of the Software, and to
14 // permit persons to whom the Software is furnished to do so, subject to
15 // the following conditions:
17 // The above copyright notice and this permission notice shall be
18 // included in all copies or substantial portions of the Software.
20 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
21 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
22 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
23 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
24 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
25 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 using System.Messaging;
30 using System.ServiceModel;
32 namespace System.ServiceModel.Channels
34 internal class PeerInputChannel : InputChannelBase
36 PeerChannelListener<IInputChannel> listener;
37 EndpointAddress local_address;
39 // FIXME: handle timeout
40 public PeerInputChannel (PeerChannelListener<IInputChannel> listener, TimeSpan timeout)
43 this.listener = listener;
46 // FIXME: how is it set?
47 public override EndpointAddress LocalAddress {
48 get { return local_address; }
51 public override IAsyncResult BeginReceive (TimeSpan timeout, AsyncCallback callback, object state)
53 throw new NotImplementedException ();
56 public override IAsyncResult BeginTryReceive (TimeSpan timeout, AsyncCallback callback, object state)
58 throw new NotImplementedException ();
61 public override IAsyncResult BeginWaitForMessage (TimeSpan timeout, AsyncCallback callback, object state)
63 throw new NotImplementedException ();
66 public override Message EndReceive (IAsyncResult result)
68 throw new NotImplementedException ();
71 public override bool EndTryReceive (IAsyncResult result, out Message message)
73 throw new NotImplementedException ();
76 public override bool EndWaitForMessage (IAsyncResult result)
78 throw new NotImplementedException ();
81 public override Message Receive (TimeSpan timeout)
83 throw new NotImplementedException ();
86 public override bool TryReceive (TimeSpan timeout, out Message message)
88 throw new NotImplementedException ();
91 public override bool WaitForMessage (TimeSpan timeout)
93 throw new NotImplementedException ();
98 protected override void OnAbort ()
100 throw new NotImplementedException ();
103 protected override void OnClose (TimeSpan timeout)
105 throw new NotImplementedException ();
108 protected override void OnOpen (TimeSpan timeout)
113 protected override IAsyncResult OnBeginOpen (TimeSpan timeout, AsyncCallback callback, object sender)
115 throw new NotImplementedException ();
118 protected override void OnEndOpen (IAsyncResult result)
120 throw new NotImplementedException ();
123 protected override IAsyncResult OnBeginClose (TimeSpan timeout, AsyncCallback callback, object sender)
125 throw new NotImplementedException ();
128 protected override void OnEndClose (IAsyncResult result)
130 throw new NotImplementedException ();