00001 #pragma once 00002 00003 #include "Message.h" 00004 00005 namespace mycq 00006 { 00007 class QueueSchema; 00008 class OnGetHandler; 00009 00011 00013 class TopicQueue 00014 { 00015 public: 00019 virtual void put(Message* message) = 0; 00020 00024 virtual void putTx(Message* message) = 0; 00025 00084 virtual void getStart(OnGetHandler* handler) = 0; 00085 00089 virtual bool getStop() = 0; 00090 00093 virtual Message* getBlankMessage() = 0; 00094 00097 virtual QueueSchema* getQueueSchema() = 0; 00098 00101 virtual int getQueueSize() = 0; 00102 00106 virtual int getMessageCount() = 0; 00107 }; 00108 }