Click here to Skip to main content
15,887,135 members
Articles / Programming Languages / XML

DotNetMQ: A Complete Message Queue System for .NET

Rate me:
Please Sign up or sign in to vote.
4.94/5 (190 votes)
23 May 2011LGPL331 min read 1.1M   53.8K   490  
A new and independent Open Source Message Queue system that is entirely built in C# and .NET framework 3.5.
/*
DotNetMQ - A Complete Message Broker For .NET
Copyright (C) 2011 Halil ibrahim KALKAN

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 */

using System;

namespace MDS.Serialization
{
    /// <summary>
    /// This interface is used to deserialize primitives and objects.
    /// Only needed Read methods designed for MDS.
    /// </summary>
    public interface IMDSDeserializer
    {
        /// <summary>
        /// Deserializes and returns a serialized byte.
        /// </summary>
        /// <returns>Deserialized byte</returns>
        byte ReadByte();

        /// <summary>
        /// Reads a byte array from deserializing stream.
        /// Created byte array may be null or empty.
        /// </summary>
        /// <returns>Deserialized string</returns>
        byte[] ReadByteArray();
        
        /// <summary>
        /// Deserializes and returns a serialized integer.
        /// </summary>
        /// <returns>Deserialized integer</returns>
        int ReadInt32();

        /// <summary>
        /// Deserializes and returns a serialized unsigned integer.
        /// </summary>
        /// <returns>Deserialized unsigned integer</returns>
        uint ReadUInt32();

        /// <summary>
        /// Deserializes and returns a serialized long.
        /// </summary>
        /// <returns>Deserialized long</returns>
        long ReadInt64();

        /// <summary>
        /// Deserializes and returns a serialized boolean.
        /// </summary>
        /// <returns>Deserialized boolean</returns>
        bool ReadBoolean();

        /// <summary>
        /// Deserializes and returns a serialized DateTime object.
        /// </summary>
        /// <returns>Deserialized DateTime object</returns>
        DateTime ReadDateTime();

        /// <summary>
        /// Deserializes and returns a serialized char using UTF8.
        /// </summary>
        /// <returns>Deserialized char</returns>
        char ReadCharUTF8();

        /// <summary>
        /// Deserializes and returns a serialized string using UTF8.
        /// Created string may be null or empty.
        /// </summary>
        /// <returns>Deserialized string</returns>
        string ReadStringUTF8();

        /// <summary>
        /// Deserializes and returns an object that implements IMDSSerializable.
        /// Object creation method is passed as parameter and used to create empty object.
        /// Created object may be null.
        /// </summary>
        /// <typeparam name="T">A class that implements IMDSSerializable</typeparam>
        /// <param name="createObjectHandler">A function that creates an empty T object</param>
        /// <returns>Deserialized object</returns>
        T ReadObject<T>(CreateSerializableObjectHandler<T> createObjectHandler) where T : IMDSSerializable;

        /// <summary>
        /// Deserializes and returns an array of objects that implements IMDSSerializable.
        /// Object creation method is passed as parameter and used to create empty object.
        /// Created array may be null or empty.
        /// </summary>
        /// <typeparam name="T">A class that implements IMDSSerializable</typeparam>
        /// <param name="createObjectHandler">A function that creates an empty T object</param>
        /// <returns>Deserialized object</returns>
        T[] ReadObjectArray<T>(CreateSerializableObjectHandler<T> createObjectHandler) where T : IMDSSerializable;
    }
}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The GNU Lesser General Public License (LGPLv3)


Written By
Founder Volosoft
Turkey Turkey
I have started programming at 14 years old using Pascal as hobby. Then I interested in web development (HTML, JavaScript, ASP...) before university.

I graduated from Sakarya University Computer Engineering. At university, I learned C++, Visual Basic.NET, C#, ASP.NET and Java. I partly implemented ARP, IP and TCP protocols in Java as my final term project.

Now, I am working on Windows and web based software development mostly using Microsoft technologies in my own company.

My open source projects:

* ABP Framework: https://abp.io
* jTable: http://jtable.org
* Others: https://github.com/hikalkan

My personal web site:

https://halilibrahimkalkan.com

Comments and Discussions