Return to pa_vamqp.h CVS log

Up to [parser3project] / parser3 / src / types

Annotation of parser3/src/types/pa_vamqp.h, revision 1.1

1.1     ! moko        1: /** @file
        !             2:        Parser: @b amqp class decls.
        !             3: 
        !             4:        Copyright (c) 2001-2025 Art. Lebedev Studio (http://www.artlebedev.com)
        !             5:        Authors: Konstantin Morshnev <moko@design.ru>
        !             6: */
        !             7: 
        !             8: #ifndef PA_VAMQP_H
        !             9: #define PA_VAMQP_H
        !            10: 
        !            11: #define IDENT_PA_VAMQP_H "$Id: pa_vamqp.h,v 1.1 2025/10/05 00:00:00 moko Exp $"
        !            12: 
        !            13: #include "classes.h"
        !            14: #include "pa_vstateless_object.h"
        !            15: 
        !            16: #ifdef WITH_AMQP
        !            17: #include <amqp.h>
        !            18: #endif
        !            19: 
        !            20: // defines
        !            21: #define VAMQP_TYPE "amqp"
        !            22: 
        !            23: // externs
        !            24: extern Methoded *amqp_class;
        !            25: 
        !            26: class VAmqp: public VStateless_object {
        !            27: public:
        !            28:        // value
        !            29:        override const char* type() const { return VAMQP_TYPE; }
        !            30:        override VStateless_class *get_class() { return amqp_class; }
        !            31: 
        !            32: #ifdef WITH_AMQP
        !            33: public: // usage
        !            34:        VAmqp(): fconnection(0), fchannel(0) {}
        !            35:        ~VAmqp() {}
        !            36: 
        !            37:        amqp_connection_state_t fconnection;
        !            38:        int fchannel;
        !            39:        bool fstop;
        !            40: 
        !            41:        amqp_connection_state_t connection() {
        !            42:                if(!fconnection)
        !            43:                        throw Exception(PARSER_RUNTIME, 0, "using uninitialized amqp object");
        !            44:                return fconnection;
        !            45:        }
        !            46: 
        !            47:        int channel() {
        !            48:                if(!fchannel)
        !            49:                        throw Exception(PARSER_RUNTIME, 0, "using uninitialized amqp object channel");
        !            50:                return fchannel;
        !            51:        }
        !            52: 
        !            53: #endif // WITH_AMQP
        !            54: };
        !            55: 
        !            56: #endif
        !            57: 
        !            58: