00001 #ifndef TESTS_ALLSEGMENTTYPES_H
00002 #define TESTS_ALLSEGMENTTYPES_H
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00028
00029
00030 #include "qpid/amqp_0_10/specification.h"
00031 #include "qpid/amqp_0_10/Header.h"
00032 #include "qpid/amqp_0_10/Body.h"
00033
00034 using namespace qpid::amqp_0_10;
00035
00036 template <class Op> size_t allSegmentTypes(Op& op) {
00037 op(Header());
00038 op(Body());
00039 op(ControlHolder(connection::Start()));
00040 op(ControlHolder(connection::StartOk()));
00041 op(ControlHolder(connection::Secure()));
00042 op(ControlHolder(connection::SecureOk()));
00043 op(ControlHolder(connection::Tune()));
00044 op(ControlHolder(connection::TuneOk()));
00045 op(ControlHolder(connection::Open()));
00046 op(ControlHolder(connection::OpenOk()));
00047
00048 op(ControlHolder(connection::Heartbeat()));
00049
00050 op(ControlHolder(connection::CloseOk()));
00051 op(ControlHolder(session::Attach()));
00052 op(ControlHolder(session::Attached()));
00053 op(ControlHolder(session::Detach()));
00054 op(ControlHolder(session::Detached()));
00055 op(ControlHolder(session::RequestTimeout()));
00056 op(ControlHolder(session::Timeout()));
00057 op(ControlHolder(session::CommandPoint()));
00058
00059
00060 op(ControlHolder(session::Completed()));
00061 op(ControlHolder(session::KnownCompleted()));
00062 op(ControlHolder(session::Flush()));
00063 op(ControlHolder(session::Gap()));
00064
00065 op(CommandHolder(execution::Sync()));
00066 op(CommandHolder(execution::Result()));
00067
00068
00069
00070 op(CommandHolder(message::Transfer()));
00071 op(CommandHolder(message::Accept()));
00072
00073 op(CommandHolder(message::Release()));
00074 op(CommandHolder(message::Acquire()));
00075
00076 op(CommandHolder(message::Subscribe()));
00077 op(CommandHolder(message::Cancel()));
00078 op(CommandHolder(message::SetFlowMode()));
00079 op(CommandHolder(message::Flow()));
00080 op(CommandHolder(message::Flush()));
00081 op(CommandHolder(message::Stop()));
00082 op(CommandHolder(tx::Select()));
00083 op(CommandHolder(tx::Commit()));
00084 op(CommandHolder(tx::Rollback()));
00085 op(CommandHolder(dtx::Select()));
00086
00087
00088
00089
00090
00091
00092
00093
00094
00095 op(CommandHolder(exchange::Declare()));
00096 op(CommandHolder(exchange::Delete()));
00097 op(CommandHolder(exchange::Query()));
00098 op(CommandHolder(exchange::Bind()));
00099 op(CommandHolder(exchange::Unbind()));
00100 op(CommandHolder(exchange::Bound()));
00101 op(CommandHolder(queue::Declare()));
00102 op(CommandHolder(queue::Delete()));
00103 op(CommandHolder(queue::Purge()));
00104 op(CommandHolder(queue::Query()));
00105
00106
00107
00108
00109
00110
00111
00112
00113
00114
00115
00116
00117
00118
00119
00120
00121
00122
00123
00124
00125
00126 return 0;
00127 }
00128 #endif