public override void Serialize(IDataWriter writer)
 {
     writer.WriteShort(msgId);
     writer.WriteUInt(timeStamp);
     writer.WriteUTF(owner);
     writer.WriteUInt(objectGenericId);
 }

		/// <summary>
		/// Ctor
		/// </summary>
		/// <param name="writers">inject with all possible writers</param>
		public DataWriterProvider(IEnumerable<IDataWriter> writers)
		{
			if (writers != null)
			{
				foreach (IDataWriter writer in writers)
				{
					if (this.DefaultWriter == null)
					{
						// TODO: decide less arbitrary way to choose default
						// without hardcoding value into IDataWriter
						this.DefaultWriter = writer;
					}

					if (!String.IsNullOrEmpty(writer.ContentType))
					{
						this.WritersByMime[writer.ContentType] = writer;
					}

					if (!String.IsNullOrEmpty(writer.ContentType))
					{
						string ext = DataWriterProvider.NormalizeExtension(writer.FileExtension);
						this.WritersByExt[ext] = writer;
					}
				}
			}
		}

 public override void Serialize(IDataWriter writer)
 {
     base.Serialize(writer);
     writer.WriteInt(mountId);
     writer.WriteDouble(date);
     writer.WriteShort(modelId);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteInt(casterId);
     writer.WriteShort(targetCellId);
     writer.WriteShort(spellId);
     writer.WriteSByte(spellLevel);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteInt(fightId);
     writer.WriteInt(sourceId);
     writer.WriteInt(targetId);
     writer.WriteBoolean(accept);
 }

 public override void Serialize(IDataWriter writer)
 {
     base.Serialize(writer);
     writer.WriteUTF(name);
     writer.WriteInt(id);
     writer.WriteSByte(relationType);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteUTF(name);
     writer.WriteShort(worldX);
     writer.WriteShort(worldY);
     writer.WriteUTF(ownername);
 }

 public virtual void Serialize(IDataWriter writer)
 {
     writer.WriteShort(cellId);
     writer.WriteSByte(zoneSize);
     writer.WriteInt(cellColor);
     writer.WriteSByte(cellsType);
 }

 public virtual void Serialize(IDataWriter writer)
 {
     writer.WriteShort(@base);
     writer.WriteShort(objectsAndMountBonus);
     writer.WriteShort(alignGiftBonus);
     writer.WriteShort(contextModif);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteInt(areaId);
     writer.WriteSByte(atLeastNbMount);
     writer.WriteSByte(atLeastNbMachine);
     writer.WriteInt(maxPrice);
 }

 public virtual void Serialize(IDataWriter writer)
 {
     writer.WriteShort(actionId);
     writer.WriteInt(sourceId);
     writer.WriteShort(effect.TypeId);
     effect.Serialize(writer);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteSByte(paymentType);
     writer.WriteBoolean(bAdd);
     writer.WriteInt(objectToMoveId);
     writer.WriteInt(quantity);
 }

 public void SetUp()
 {
     mock=new MockRepository();
     dataWriter = mock.DynamicMock<IDataWriter>();
     dataReader = mock.Stub<IDataReader>();
     randomSecret = mock.Stub<IRandomSecret>();
 }

 public override void Serialize(IDataWriter writer)
 {
     base.Serialize(writer);
     writer.WriteShort(firstNameId);
     writer.WriteShort(lastNameId);
     writer.WriteShort(level);
 }

 public override void Serialize(IDataWriter writer)
 {
     base.Serialize(writer);
     writer.WriteInt(targetId);
     writer.WriteInt(spellId);
     writer.WriteShort(value);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteShort(fightId);
     writer.WriteSByte(teamId);
     writer.WriteSByte(option);
     writer.WriteBoolean(state);
 }

        // Process the client connection.
        private static void DoAcceptTcpClientCallback(IAsyncResult ar, IDataWriter writer, IDataGetter reader, CancellationToken ct)
        {
            if (ct.IsCancellationRequested)
                return;
            // Get the listener that handles the client request.
            var listener = (TcpListener)ar.AsyncState;

            // End the operation
            var client = listener.EndAcceptTcpClient(ar);

            client.ReceiveTimeout = TimingConstants.ClientCommunicationTimeout;
            client.SendTimeout = TimingConstants.ClientCommunicationTimeout;
            writer.Log(new LogItem("New client is coming!", ((IPEndPoint)client.Client.RemoteEndPoint).Address.ToString()));
            try
            {
                var currentClient = new ClientThread(client, writer, reader);
                //
                Task.Run(() => currentClient.Execute(ct), ct);
            }
            catch (Exception e)
            {
                writer.Log(new LogItem("Server got an exception when client arrived: " + e.Message, "no ip"));
            }

            // Signal the calling thread to continue.
            _tcpClientConnected.Set();
        }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteInt(entityId);
     writer.WriteInt(elemId);
     writer.WriteShort(skillId);
     writer.WriteShort(duration);
 }

 public override void Serialize(IDataWriter writer)
 {
     writer.WriteDouble(mountUid);
     writer.WriteSByte(mountLocation);
     writer.WriteInt(mountFoodUid);
     writer.WriteInt(quantity);
 }

 public override void Serialize(IDataWriter writer)
 {
     base.Serialize(writer);
     writer.WriteByte(position);
     writer.WriteInt(spellId);
     writer.WriteSByte(spellLevel);
 }