using System.Net;
using System.Net.Sockets;
using System.ServiceModel;
+using System.ServiceModel.Channels.NetTcp;
using System.Text;
using System.Threading;
if (message.Headers.RelatesTo == null)
message.Headers.RelatesTo = request.Headers.MessageId;
- DateTime start = DateTime.Now;
owner.frame.WriteUnsizedMessage (message, timeout);
owner.frame.WriteEndRecord ();
owner.server.Close ();
public override bool TryReceiveRequest (TimeSpan timeout, out RequestContext context)
{
try {
- DateTime start = DateTime.Now;
context = ReceiveRequest (timeout);
return context != null;
} catch (TimeoutException) {
protected override void OnOpen (TimeSpan timeout)
{
- DateTime start = DateTime.Now;
-
// FIXME: use timeout
frame = new TcpBinaryFrameManager (TcpBinaryFrameManager.SingletonUnsizedMode, server, true) { Encoder = this.Encoder };
frame.ProcessPreambleRecipient ();