cMessageQueue.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cMessageQueue_H
#define _INC_cMessageQueue_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "../GrayLibBase.h"
 
namespace GrayLib
{
        interface IMessageInQueue
        {
 
                // should be synchronous, that is when it completes, 
                // we want to be sure(what sure means exactly may vary) that the messages are sent
                void send();
 
                // should receive messages from the queue and block them; 
                // if the node crashes, the messages should be returned to the queue and re - delivered
                void receive();
 
                // acknowledge delivery and processing of the messages. This message is done.
                // Acknowledgments can be asynchronous, that is we don’t have to be sure that the messages really got deleted.
                void ack();
        };
 
        class GRAYLIB_LINK cMessageQueue
        {
 
        public:
                cMessageQueue();
                virtual ~cMessageQueue();
        };
 
}
 
#endif