MqCall_cc.hh

Go to the documentation of this file.

 
/* LABEL-NO */
 
#pragma once
 
#include "LibMqMsgque_cc.hh"
 
namespace ccmqmsgque {
 
  struct MqServiceCallbackC {
    enum MqServiceCallbackE  {
      PC_MqTokenICB,
      PC_MqTokenCCB,
      PC_MqServiceIF,
      PC_MqEventIF,
      PC_MqServerSetupIF,
      PC_MqServerCleanupIF,
      PC_MqBgErrorIF
    } type;
 
    union MqServiceCallbackU {
      MqContextC::MqTokenICB    Callback; 
      MqContextC::MqTokenCCB    StaticCallback; 
      MqServiceIF *             Service;
      MqEventIF *               Event;
      MqServerSetupIF *         ServerSetup;
      MqServerCleanupIF *       ServerCleanup;
      MqBgErrorIF *             BgError;
 
      MqServiceCallbackU  (  MqContextC::MqTokenICB   cb  )  :  Callback        (cb)  {}
      MqServiceCallbackU  (  MqContextC::MqTokenCCB   cb  )  :  StaticCallback  (cb)  {}
      MqServiceCallbackU  (  MqServiceIF*             cb  )  :  Service         (cb)  {}
      MqServiceCallbackU  (  MqEventIF*               cb  )  :  Event           (cb)  {}
      MqServiceCallbackU  (  MqServerSetupIF*         cb  )  :  ServerSetup     (cb)  {}
      MqServiceCallbackU  (  MqServerCleanupIF*       cb  )  :  ServerCleanup   (cb)  {}
      MqServiceCallbackU  (  MqBgErrorIF*             cb  )  :  BgError         (cb)  {}
 
    } call;
 
    MqContextC *self;
 
    private:
      MqServiceCallbackC(enum MqServiceCallbackE type, union MqServiceCallbackU call, MqContextC *self) : \
        type(type), call(call), self(self) {};
 
    public:
 
      static MK_CBP Create(MK_RT_ARGS MqContextC::MqTokenICB const callback, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqTokenICB,callback, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqContextC::MqTokenCCB const callback, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqTokenCCB,callback, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqServiceIF * const service, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqServiceIF,service, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqEventIF * const event, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqEventIF,event, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqServerSetupIF * const serverSetup, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqServerSetupIF,serverSetup, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqServerCleanupIF * const serverCleanup, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqServerCleanupIF,serverCleanup, self);
      }
      static MK_CBP Create(MK_RT_ARGS MqBgErrorIF * const bgError, MqContextC *self = NULL) {
        return new MqServiceCallbackC(PC_MqBgErrorIF,bgError, self);
      }
      static MK_CBP Create(MK_RT_ARGS MQ_CTX const context, MqServiceCallbackC* const copy, MqContextC *self = NULL);
 
      static enum MkErrorE  Call ( MQ_SERVICE_CALL_ARGS );
      static void           Free ( MQ_SERVICE_FREE_ARGS );
      static void           Copy ( MQ_SERVICE_COPY_ARGS );
  };  
 
  typedef struct MqServiceCallbackC MqBgErrorCallbackC;
  typedef struct MqServiceCallbackC MqEventCallbackC;
  typedef struct MqServiceCallbackC MqServerSetupCallbackC;
  typedef struct MqServiceCallbackC MqServerCleanupCallbackC;
};