MqContextC_Service_CC_API

MqContextC - create and manage a service … More...

Collaboration diagram for MqContextC_Service_CC_API:

Functions
void	ccmqmsgque::MqContextC::ServiceCreate (MQ_TOK token, MqServiceCCB callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceCreate (const std::string &token, MqServiceCCB callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceCreate (MQ_TOK token, MqServiceICB callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceCreate (const std::string &token, MqServiceICB callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceCreate (MQ_TOK token, MqServiceIF *callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceCreate (const std::string &token, MqServiceIF *callback)
	C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API create a link between a service-token and a service-callback …
void	ccmqmsgque::MqContextC::ServiceDelete (MQ_TOK token)
	C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
void	ccmqmsgque::MqContextC::ServiceDelete (const std::string &token)
	C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
MK_BOOL	ccmqmsgque::MqContextC::ServiceIsTransaction ()
	C++: MK_BOOL ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a transaction …
void	ccmqmsgque::MqContextC::ServiceProxy (MQ_TOK token, MQ_SLAVE_ID id=MQ_SLAVE_OTHER)
	C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API create a service to link a master-context with a slave-context. …
void	ccmqmsgque::MqContextC::ServiceProxy (const std::string &token, MQ_SLAVE_ID id=MQ_SLAVE_OTHER)
	C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API create a service to link a master-context with a slave-context. …
void	ccmqmsgque::MqContextC::ServiceProxyCtx (MQ_TOK token, MqContextC *target)
	C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but use an MqContextC as input.
void	ccmqmsgque::MqContextC::ServiceProxyCtx (MQ_TOK token, const MqContextC &target)
	C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but use an MqContextC as input.
void	ccmqmsgque::MqContextC::ServiceProxyCtx (const std::string &token, MqContextC *target)
	C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but use an MqContextC as input.
void	ccmqmsgque::MqContextC::ServiceProxyCtx (const std::string &token, const MqContextC &target)
	C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but use an MqContextC as input.
MK_BOOL	ccmqmsgque::MqContextC::ServiceProxyCtxExists (MQ_TOK token, MqContextC *target)
	C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if service who belongs to token is a proxy-service
MK_BOOL	ccmqmsgque::MqContextC::ServiceProxyCtxExists (MQ_TOK token, const MqContextC &target)
	C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if service who belongs to token is a proxy-service
MK_BOOL	ccmqmsgque::MqContextC::ServiceProxyCtxExists (const std::string &token, MqContextC *target)
	C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if service who belongs to token is a proxy-service
MK_BOOL	ccmqmsgque::MqContextC::ServiceProxyCtxExists (const std::string &token, const MqContextC &target)
	C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if service who belongs to token is a proxy-service
void	ccmqmsgque::MqContextC::ServiceProxyRoundRobin (MQ_TOK token, MK_STRN ident)
	C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service using Round-Robin as load-balancer …
void	ccmqmsgque::MqContextC::ServiceProxyRoundRobin (const std::string &token, const std::string &ident)
	C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service using Round-Robin as load-balancer …
void	ccmqmsgque::MqContextC::ServiceStorage (MQ_TOK token)
	C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …
void	ccmqmsgque::MqContextC::ServiceStorage (const std::string &token)
	C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …
MK_BOOL	ccmqmsgque::MqContextC::ServiceTokenCheck (MQ_TOK token)
	C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
MK_BOOL	ccmqmsgque::MqContextC::ServiceTokenCheck (const std::string &token)
	C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
MK_BOOL	ccmqmsgque::MqContextC::ServiceTokenExists (MQ_TOK token)
	C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
MK_BOOL	ccmqmsgque::MqContextC::ServiceTokenExists (const std::string &token)
	C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
MQ_TOK	ccmqmsgque::MqContextC::ServiceTokenGet ()
	C++: MQ_TOK ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …

Detailed Description

MqContextC - create and manage a service …

To provide a service is the main purpose of a server and the main-purpose of a client/server connection is to call a service and to process the result.
A service can be defined on the server or on the client. On the server a service can be initial setup with MqServerSetupIF method and finally cleanup with MqServerCleanupIF.

‍A service is created with the MqServiceCreate and deleted with the MqServiceDelete.

A service can be created and deleted during the entire life-cycle of the server or the client. If the server/client-context is deleted all services of the are deleted also.

‍A MqServiceDelete is not required.

Creating or deleting a service is like granting or revoking the right to access a single feature.

eventloop

To receive a data-package on a service the event-loop have to be active. The event-loop ia always active on an synchronous-service-call . On a server the event-loop is started with MqProcessEvent at startup.

synchronous-service-call

A synchronous-service-call always block and enter the event-loop to wait for an answer

asynchronous-service-call

A asynchronous-service-call always return immediately and the possible result is received on a callback

callback

A callback is the function called by a service and required to receive data from remote.
A callback is created with MqServiceCreate or is part of the service-call.
A callback can be a service-identifer or a service-callback.

service-call with callback

SendEND_AND_CALLBACK, SendEND_AND_SUB, SendEND_AND_TRANSACTION

service-call without callback

SendEND, SendEND_AND_WAIT

Example from MyServer.cc → define the service SRV1 on the server-link-setup

#include "LibMqMsgque_cc.hh"

using namespace ccmqmsgque;

// package-item
class MyServer : public MqContextC, public MqServerSetupIF {
  friend class MqFactoryCT<MyServer>;
  private:
    // define the factory constructor
    MyServer(MK_TYP const typ, MqContextC* tmpl=NULL) : MqContextC(typ,tmpl) {};

  private:
    // service to serve all incoming requests for token "HLWO"
    void MyFirstService () {
      SendSTART();
      SendV("%s World", ReadSTR());
      SendRETURN();
    }

    // define a service as link between the token "HLWO" and the callback "MyFirstService"
    void ServerSetup() {
      ServiceCreate("HLWO", MqServiceICB(&MyServer::MyFirstService));
    }
};

// package-main
int MK_CDECL main(int argc, MK_STRN argv[]) {
  MqMsgque::Setup();

  // setup commandline arguments for later use
  MkBufferListC largs = {argc, argv};
  // create "MyServer" factory… and make it to the default.
  MqFactoryCT<MyServer>::Add("MyServer")->Default();
  // inspect commandline-argument for the "factory" to choose… and create a object
  auto srv = MqFactoryCT<MqContextC>::GetCalled(largs)->New();
  // start listen for incoming call's
  try {
    srv->LinkCreate(largs);
    srv->ProcessEvent (MQ_WAIT_FOREVER);
  } catch (const std::exception& e) {
    srv->ErrorCatch(e);
  }
  srv->Exit();
}

To provide a service is the main purpose of a server and the main-purpose of a client/server connection is to call a service and to process the result.
A service can be defined on the server or on the client. On the server a service can be initial setup with MqServerSetupIF method and finally cleanup with MqServerCleanupIF.

‍A service is created with the MqServiceCreate and deleted with the MqServiceDelete.

A service can be created and deleted during the entire life-cycle of the server or the client. If the server/client-context is deleted all services of the are deleted also.

‍A MqServiceDelete is not required.

Creating or deleting a service is like granting or revoking the right to access a single feature.

eventloop

To receive a data-package on a service the event-loop have to be active. The event-loop ia always active on an synchronous-service-call . On a server the event-loop is started with MqProcessEvent at startup.

synchronous-service-call

A synchronous-service-call always block and enter the event-loop to wait for an answer

asynchronous-service-call

A asynchronous-service-call always return immediately and the possible result is received on a callback

callback

A callback is the function called by a service and required to receive data from remote.
A callback is created with MqServiceCreate or is part of the service-call.
A callback can be a service-identifer or a service-callback.

service-call with callback

SendEND_AND_CALLBACK, SendEND_AND_SUB, SendEND_AND_TRANSACTION

service-call without callback

SendEND, SendEND_AND_WAIT

Example from MyServer.cc → define the service SRV1 on the server-link-setup

#include "LibMqMsgque_cc.hh"

using namespace ccmqmsgque;

// package-item
class MyServer : public MqContextC, public MqServerSetupIF {
  friend class MqFactoryCT<MyServer>;
  private:
    // define the factory constructor
    MyServer(MK_TYP const typ, MqContextC* tmpl=NULL) : MqContextC(typ,tmpl) {};

  private:
    // service to serve all incoming requests for token "HLWO"
    void MyFirstService () {
      SendSTART();
      SendV("%s World", ReadSTR());
      SendRETURN();
    }

    // define a service as link between the token "HLWO" and the callback "MyFirstService"
    void ServerSetup() {
      ServiceCreate("HLWO", MqServiceICB(&MyServer::MyFirstService));
    }
};

// package-main
int MK_CDECL main(int argc, MK_STRN argv[]) {
  MqMsgque::Setup();

  // setup commandline arguments for later use
  MkBufferListC largs = {argc, argv};
  // create "MyServer" factory… and make it to the default.
  MqFactoryCT<MyServer>::Add("MyServer")->Default();
  // inspect commandline-argument for the "factory" to choose… and create a object
  auto srv = MqFactoryCT<MqContextC>::GetCalled(largs)->New();
  // start listen for incoming call's
  try {
    srv->LinkCreate(largs);
    srv->ProcessEvent (MQ_WAIT_FOREVER);
  } catch (const std::exception& e) {
    srv->ErrorCatch(e);
  }
  srv->Exit();
}

Function Documentation

ServiceCreate() [1/6]

void ccmqmsgque::MqContextC::ServiceCreate ( const std::string & token, MqServiceCCB callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2108 of file MqContextC_inline_cc.hh.

                                                                                       {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

ServiceCreate() [2/6]

void ccmqmsgque::MqContextC::ServiceCreate ( const std::string & token, MqServiceICB callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2127 of file MqContextC_inline_cc.hh.

                                                                                       {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

ServiceCreate() [3/6]

void ccmqmsgque::MqContextC::ServiceCreate ( const std::string & token, MqServiceIF * callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2146 of file MqContextC_inline_cc.hh.

                                                                                       {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token_hdl, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

ServiceCreate() [4/6]

void ccmqmsgque::MqContextC::ServiceCreate ( MQ_TOK token, MqServiceCCB callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2099 of file MqContextC_inline_cc.hh.

                                                                             {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

Here is the caller graph for this function:

ServiceCreate() [5/6]

void ccmqmsgque::MqContextC::ServiceCreate ( MQ_TOK token, MqServiceICB callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2118 of file MqContextC_inline_cc.hh.

                                                                             {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

ServiceCreate() [6/6]

void ccmqmsgque::MqContextC::ServiceCreate ( MQ_TOK token, MqServiceIF * callback )

inline

C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) → C-API
create a link between a service-token and a service-callback …

Definition at line 2137 of file MqContextC_inline_cc.hh.

                                                                             {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    auto callback_ptr = MqServiceCallbackC::Create(MK_RT_CALL callback, this);
    enum MkErrorE errVal = MqServiceCreate(ctx, token, MqServiceCallbackC::Call, callback_ptr, MqServiceCallbackC::Free, NULL);
    MkErrorC_Check(ctx, errVal);
  }

ServiceDelete() [1/2]

void ccmqmsgque::MqContextC::ServiceDelete ( const std::string & token )

inline

C++: ctx.ServiceDelete(MQ_TOK token) → C-API
delete a service. …

Definition at line 2164 of file MqContextC_inline_cc.hh.

                                                                {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    enum MkErrorE errVal = MqServiceDelete(ctx, token_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceDelete() [2/2]

void ccmqmsgque::MqContextC::ServiceDelete ( MQ_TOK token )

inline

C++: ctx.ServiceDelete(MQ_TOK token) → C-API
delete a service. …

Definition at line 2156 of file MqContextC_inline_cc.hh.

                                                      {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    enum MkErrorE errVal = MqServiceDelete(ctx, token);
    MkErrorC_Check(ctx, errVal);
  }

ServiceIsTransaction()

MK_BOOL ccmqmsgque::MqContextC::ServiceIsTransaction ( )

inline

C++: MK_BOOL ctx.ServiceIsTransaction() → C-API
check if the ongoing-service-call belongs to a transaction …

Definition at line 2173 of file MqContextC_inline_cc.hh.

                                                    {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MK_BOOL __retVal__L = MqServiceIsTransaction(ctx);
    return __retVal__L;
  }

ServiceProxy() [1/2]

void ccmqmsgque::MqContextC::ServiceProxy ( const std::string & token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER )

inline

C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API
create a service to link a master-context with a slave-context. …

Definition at line 2189 of file MqContextC_inline_cc.hh.

                                                                               {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    enum MkErrorE errVal = MqServiceProxy(ctx, token_hdl, id);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxy() [2/2]

void ccmqmsgque::MqContextC::ServiceProxy ( MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER )

inline

C++: ctx.ServiceProxy(MQ_TOK token, MQ_SLAVE_ID id = MQ_SLAVE_OTHER) → C-API
create a service to link a master-context with a slave-context. …

Definition at line 2181 of file MqContextC_inline_cc.hh.

                                                                     {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    enum MkErrorE errVal = MqServiceProxy(ctx, token, id);
    MkErrorC_Check(ctx, errVal);
  }

Here is the caller graph for this function:

ServiceProxyCtx() [1/4]

void ccmqmsgque::MqContextC::ServiceProxyCtx ( const std::string & token, const MqContextC & target )

inline

C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API
same as MqServiceProxy but use an MqContextC as input.

Definition at line 2226 of file MqContextC_inline_cc.hh.

                                                                                            {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    const MQ_CTX target_hdl = MqContextC::getCTX(target);
    enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxyCtx() [2/4]

void ccmqmsgque::MqContextC::ServiceProxyCtx ( const std::string & token, MqContextC * target )

inline

C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API
same as MqServiceProxy but use an MqContextC as input.

Definition at line 2216 of file MqContextC_inline_cc.hh.

                                                                                      {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    MQ_CTX target_hdl = MqContextC::getCTX(target);
    enum MkErrorE errVal = MqServiceProxyCtx(ctx, token_hdl, target_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxyCtx() [3/4]

void ccmqmsgque::MqContextC::ServiceProxyCtx ( MQ_TOK token, const MqContextC & target )

inline

C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API
same as MqServiceProxy but use an MqContextC as input.

Definition at line 2207 of file MqContextC_inline_cc.hh.

                                                                                  {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MQ_CTX target_hdl = MqContextC::getCTX(target);
    enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxyCtx() [4/4]

void ccmqmsgque::MqContextC::ServiceProxyCtx ( MQ_TOK token, MqContextC * target )

inline

C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API
same as MqServiceProxy but use an MqContextC as input.

Definition at line 2198 of file MqContextC_inline_cc.hh.

                                                                            {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MQ_CTX target_hdl = MqContextC::getCTX(target);
    enum MkErrorE errVal = MqServiceProxyCtx(ctx, token, target_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxyCtxExists() [1/4]

MK_BOOL ccmqmsgque::MqContextC::ServiceProxyCtxExists ( const std::string & token, const MqContextC & target )

inline

C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API
check if service who belongs to token is a proxy-service

Definition at line 2264 of file MqContextC_inline_cc.hh.

                                                                                                     {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    const MQ_CTX target_hdl = MqContextC::getCTX(target);
    MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
    return __retVal__L;
  }

ServiceProxyCtxExists() [2/4]

MK_BOOL ccmqmsgque::MqContextC::ServiceProxyCtxExists ( const std::string & token, MqContextC * target )

inline

C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API
check if service who belongs to token is a proxy-service

Definition at line 2254 of file MqContextC_inline_cc.hh.

                                                                                               {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    MQ_CTX target_hdl = MqContextC::getCTX(target);
    MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token_hdl, target_hdl);
    return __retVal__L;
  }

ServiceProxyCtxExists() [3/4]

MK_BOOL ccmqmsgque::MqContextC::ServiceProxyCtxExists ( MQ_TOK token, const MqContextC & target )

inline

C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API
check if service who belongs to token is a proxy-service

Definition at line 2245 of file MqContextC_inline_cc.hh.

                                                                                           {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MQ_CTX target_hdl = MqContextC::getCTX(target);
    MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
    return __retVal__L;
  }

ServiceProxyCtxExists() [4/4]

MK_BOOL ccmqmsgque::MqContextC::ServiceProxyCtxExists ( MQ_TOK token, MqContextC * target )

inline

C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API
check if service who belongs to token is a proxy-service

Definition at line 2236 of file MqContextC_inline_cc.hh.

                                                                                     {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MQ_CTX target_hdl = MqContextC::getCTX(target);
    MK_BOOL __retVal__L = MqServiceProxyCtxExists(ctx, token, target_hdl);
    return __retVal__L;
  }

ServiceProxyRoundRobin() [1/2]

void ccmqmsgque::MqContextC::ServiceProxyRoundRobin ( const std::string & token, const std::string & ident )

inline

C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API
create a proxy-service using Round-Robin as load-balancer …

Definition at line 2282 of file MqContextC_inline_cc.hh.

                                                                                                 {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    const MK_STRN ident_hdl = ident.c_str();
    enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token_hdl, ident_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceProxyRoundRobin() [2/2]

void ccmqmsgque::MqContextC::ServiceProxyRoundRobin ( MQ_TOK token, MK_STRN ident )

inline

C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API
create a proxy-service using Round-Robin as load-balancer …

Definition at line 2274 of file MqContextC_inline_cc.hh.

                                                                              {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    enum MkErrorE errVal = MqServiceProxyRoundRobin(ctx, token, ident);
    MkErrorC_Check(ctx, errVal);
  }

ServiceStorage() [1/2]

void ccmqmsgque::MqContextC::ServiceStorage ( const std::string & token )

inline

C++: ctx.ServiceStorage(MQ_TOK token) → C-API
setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …

Definition at line 2300 of file MqContextC_inline_cc.hh.

                                                                 {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    enum MkErrorE errVal = MqServiceStorage(ctx, token_hdl);
    MkErrorC_Check(ctx, errVal);
  }

ServiceStorage() [2/2]

void ccmqmsgque::MqContextC::ServiceStorage ( MQ_TOK token )

inline

C++: ctx.ServiceStorage(MQ_TOK token) → C-API
setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …

Definition at line 2292 of file MqContextC_inline_cc.hh.

                                                       {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    enum MkErrorE errVal = MqServiceStorage(ctx, token);
    MkErrorC_Check(ctx, errVal);
  }

Here is the caller graph for this function:

ServiceTokenCheck() [1/2]

MK_BOOL ccmqmsgque::MqContextC::ServiceTokenCheck ( const std::string & token )

inline

C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …

Definition at line 2317 of file MqContextC_inline_cc.hh.

                                                                       {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token_hdl);
    return __retVal__L;
  }

ServiceTokenCheck() [2/2]

MK_BOOL ccmqmsgque::MqContextC::ServiceTokenCheck ( MQ_TOK token )

inline

C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …

Definition at line 2309 of file MqContextC_inline_cc.hh.

                                                             {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MK_BOOL __retVal__L = MqServiceTokenCheck(ctx, token);
    return __retVal__L;
  }

ServiceTokenExists() [1/2]

MK_BOOL ccmqmsgque::MqContextC::ServiceTokenExists ( const std::string & token )

inline

C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …

Definition at line 2334 of file MqContextC_inline_cc.hh.

                                                                        {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    const MK_STRN token_hdl = token.c_str();
    MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token_hdl);
    return __retVal__L;
  }

ServiceTokenExists() [2/2]

MK_BOOL ccmqmsgque::MqContextC::ServiceTokenExists ( MQ_TOK token )

inline

C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …

Definition at line 2326 of file MqContextC_inline_cc.hh.

                                                              {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MK_BOOL __retVal__L = MqServiceTokenExists(ctx, token);
    return __retVal__L;
  }

ServiceTokenGet()

MQ_TOK ccmqmsgque::MqContextC::ServiceTokenGet ( )

inline

C++: MQ_TOK ctx.ServiceTokenGet() → C-API
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …

Definition at line 2343 of file MqContextC_inline_cc.hh.

                                              {
    MK_UNUSED auto ctx = getCTX();
    MkRtSetup_X(ctx);
    MQ_TOK __retVal__L = MqServiceTokenGet(ctx);
    return __retVal__L;
  }