00001
00002
00003
00004
00005
00006
00007
00008 #ifndef __QUEUEFILLREQUEST_H__
00009 #define __QUEUEFILLREQUEST_H__
00010
00011 #include "Tools/Streams/InOut.h"
00012
00013
00014
00015
00016
00017 class QueueFillRequest
00018 {
00019 public:
00020
00021 typedef enum QueueFillMode{
00022 immediateReadWrite,
00023 collectNSeconds,
00024 toStickNSeconds,
00025 overwriteOlder,
00026 rejectAll,
00027 toStickImmediately,
00028 collect,
00029 saveCollected,
00030 sendCollected,
00031 blockNewMessages
00032 } QueueFillMode;
00033
00034
00035 QueueFillRequest():mode(immediateReadWrite),seconds(0) {}
00036
00037
00038
00039
00040
00041 QueueFillRequest(QueueFillMode qfm, long sec=1):mode(qfm),seconds(sec) {}
00042
00043
00044 QueueFillMode mode;
00045
00046
00047 long seconds;
00048 };
00049
00050
00051
00052
00053
00054
00055
00056 In& operator>>(In& stream,QueueFillRequest& queueFillRequest);
00057
00058
00059
00060
00061
00062
00063
00064 Out& operator<<(Out& stream, const QueueFillRequest& queueFillRequest);
00065
00066 #endif // __QUEUEFILLREQUEST_H__