Isolated socket from MQ implementation.

DtronixMessageQueue/MqSession.cs

@@ -33,6 +33,11 @@ public abstract class MqSession<TSession> : SocketSession
 		/// </summary>
 		private MqMessage message;
 
+		/// <summary>
+		/// Internal framebuilder for this instance.
+		/// </summary>
+		private MqFrameBuilder frame_builder;
+
 		/// <summary>
 		/// Outbox message queue.  Internally used to store Messages before being sent to the wire by the Postmaster.
 		/// </summary>
@@ -53,6 +58,10 @@ public abstract class MqSession<TSession> : SocketSession
 		/// </summary>
 		public SocketBase<TSession> BaseSocket { get; set; }
 
+		protected override void OnSetup() {
+			frame_builder = new MqFrameBuilder((MqSocketConfig)Config);
+		}
+
 		/// <summary>
 		/// Adds bytes from the client/server reading methods to be processed by the Postmaster.
 		/// </summary>

DtronixMessageQueue/Socket/SocketSession.cs

@@ -60,20 +60,17 @@ public enum State : byte {
 		/// </summary>
 		public State CurrentState { get; protected set; }
 
-
 		/// <summary>
-		/// Internal framebuilder for this instance.
+		/// The last time that this session received a message.
 		/// </summary>
-		protected MqFrameBuilder frame_builder;
-
 		private DateTime last_received = DateTime.UtcNow;
 
 		/// <summary>
 		/// Last time the session received anything from the socket.  Time in UTC.
 		/// </summary>
 		public DateTime LastReceived => last_received;
 
-		protected System.Net.Sockets.Socket socket;
+		private System.Net.Sockets.Socket socket;
 
 		/// <summary>
 		/// Raw socket for this session.
@@ -132,7 +129,6 @@ public static void Setup(SocketSession session, System.Net.Sockets.Socket socket
 			session.send_args.Completed += session.IoCompleted;
 			session.receive_args = args_pool.Pop();
 			session.receive_args.Completed += session.IoCompleted;
-			session.frame_builder = new MqFrameBuilder((MqSocketConfig)config);
 
 			session.socket = socket;
 			session.write_reset = new ManualResetEventSlim(true);