123 MkErrorC_Check(ctx, errVal);
132 MkErrorC_Check(ctx, errVal);
148 MkErrorC_Check(ctx, errVal);
155 const MK_STRN ident_hdl = ident.c_str();
157 MkErrorC_Check(ctx, errVal);
183 MkErrorC_Check(ctx, errVal);
314 MkErrorC_Check(ctx, errVal);
321 const MK_STRN filename_hdl = filename.c_str();
323 MkErrorC_Check(ctx, errVal);
337 MkErrorC_Check(ctx, errVal);
338 std::tuple<MK_STRN,MK_STRN,MK_STRN,MK_STRN> __retVal__L = {host_out,port_out,myhost_out,myport_out};
357 if (callback_ptr == NULL) fCall = NULL;
367 if (callback_ptr == NULL) fCall = NULL;
377 if (callback_ptr == NULL) fCall = NULL;
387 if (callback_ptr == NULL) fCall = NULL;
397 if (callback_ptr == NULL) fCall = NULL;
407 if (callback_ptr == NULL) fCall = NULL;
417 if (callback_ptr == NULL) fCall = NULL;
427 if (callback_ptr == NULL) fCall = NULL;
437 if (callback_ptr == NULL) fCall = NULL;
447 if (callback_ptr == NULL) fCall = NULL;
457 if (callback_ptr == NULL) fCall = NULL;
467 if (callback_ptr == NULL) fCall = NULL;
509 MkErrorC_Check(ctx, errVal);
524 MkErrorC_Check(ctx, errVal);
531 const MK_STRN pidfile_hdl = pidfile.c_str();
533 MkErrorC_Check(ctx, errVal);
555 MkErrorC_Check(ctx, errVal);
563 MkErrorC_Check(ctx, errVal);
572 MkErrorC_Check(ctx, errVal);
581 MkErrorC_Check(ctx, errVal);
589 MkErrorC_Check(ctx, errVal);
596 const MK_STRN file_hdl = file.c_str();
598 MkErrorC_Check(ctx, errVal);
626 const MK_STRN data_hdl = data.c_str();
648 const MK_STRN data_hdl = data.c_str();
663 const MK_STRN data_hdl = data.c_str();
672 MkErrorC_Check(ctx, errVal);
680 MkErrorC_Check(ctx, errVal);
687 const MK_STRN data_hdl = data.c_str();
689 MkErrorC_Check(ctx, errVal);
703 const MK_STRN data_hdl = data.c_str();
806 MkErrorC_Check(ctx, errVal);
813 const MK_STRN cstr_hdl = cstr.c_str();
815 MkErrorC_Check(ctx, errVal);
842 MkErrorC_Check(ctx, errVal);
851 MkErrorC_Check(ctx, errVal);
860 MkErrorC_Check(ctx, errVal);
870 MkErrorC_Check(ctx, errVal);
880 MkErrorC_Check(ctx, errVal);
927 MkErrorC_Check(ctx, errVal);
944 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
954 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
964 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
974 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
984 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
994 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1004 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1014 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1024 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1034 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1044 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1054 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1064 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1074 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1134 if (callline == -1) {callline = __builtin_LINE();}
1135 if (callfile == NULL) {callfile = __builtin_FILE();}
1136 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
1137 MqExit(ctx, callfunc, callfile, callline);
1145 MkErrorC_Check(ctx, errVal);
1164 MkErrorC_Check(sourceCtx, errVal);
1174 MkErrorC_Check(sourceCtx, errVal);
1183 MkErrorC_Check(sourceCtx, errVal);
1192 MkErrorC_Check(sourceCtx, errVal);
1210 MkErrorC_Check(ctx, errVal);
1222 MkErrorC_Check(ctx, errVal);
1232 MkErrorC_Check(ctx, errVal);
1245 MK_BNP val_out = std::make_pair(val_out_ref.
size,val_out_ref.
data);
1255 MkErrorC_Check(ctx, errVal);
1256 return val_out != 0;
1266 MK_BNP val_out = std::make_pair(val_out_ref.
size,val_out_ref.
data);
1276 MkErrorC_Check(ctx, errVal);
1286 MkErrorC_Check(ctx, errVal);
1296 MkErrorC_Check(ctx, errVal);
1306 MkErrorC_Check(ctx, errVal);
1316 MkErrorC_Check(ctx, errVal);
1326 MkErrorC_Check(ctx, errVal);
1336 MkErrorC_Check(ctx, errVal);
1337 return (
MK_I8)val_out;
1349 MkErrorC_Check(ctx, errVal);
1362 MkErrorC_Check(ctx, errVal);
1373 const std::string& val_out = std::string(val_out_ref.
ptr,val_out_ref.
len);
1391 MkErrorC_Check(ctx, errVal);
1400 MkErrorC_Check(ctx, errVal);
1409 MkErrorC_Check(ctx, errVal);
1417 MkErrorC_Check(ctx, errVal);
1425 MkErrorC_Check(ctx, errVal);
1473 MkErrorC_Check(ctx, errVal);
1491 MkErrorC_Check(ctx, errVal);
1502 MkErrorC_Check(ctx, errVal);
1509 const MK_STRN route_hdl = route.c_str();
1510 const MK_STRN service_hdl = service.c_str();
1512 MkErrorC_Check(ctx, errVal);
1520 MkErrorC_Check(ctx, errVal);
1527 const MK_STRN route_hdl = route.c_str();
1528 const MK_STRN service_hdl = service.c_str();
1530 MkErrorC_Check(ctx, errVal);
1538 static __thread
MK_NUM szret = 0;
1540 if (__retVal__L.
size+1 > szret) {
1541 szret=__retVal__L.
size*2+1;
1545 for (num=0; num<__retVal__L.
size; num++) {
1556 const MK_STRN ident_hdl = ident.c_str();
1558 static __thread
MK_NUM szret = 0;
1560 if (__retVal__L.
size+1 > szret) {
1561 szret=__retVal__L.
size*2+1;
1565 for (num=0; num<__retVal__L.
size; num++) {
1578 MkErrorC_Check(ctx, errVal);
1587 MkErrorC_Check(ctx, errVal);
1594 const MK_STRN service_hdl = service.c_str();
1597 MkErrorC_Check(ctx, errVal);
1604 const MK_STRN service_hdl = service.c_str();
1607 MkErrorC_Check(ctx, errVal);
1618 MkErrorC_Check(ctx, errVal);
1637 MkErrorC_Check(ctx, errVal);
1646 MkErrorC_Check(ctx, errVal);
1655 MkErrorC_Check(ctx, errVal);
1663 MkErrorC_Check(ctx, errVal);
1672 MkErrorC_Check(ctx, errVal);
1681 MkErrorC_Check(ctx, errVal);
1690 MkErrorC_Check(ctx, errVal);
1699 MkErrorC_Check(ctx, errVal);
1708 MkErrorC_Check(ctx, errVal);
1716 MkErrorC_Check(ctx, errVal);
1724 MkErrorC_Check(ctx, errVal);
1732 MkErrorC_Check(ctx, errVal);
1740 MkErrorC_Check(ctx, errVal);
1748 MkErrorC_Check(ctx, errVal);
1756 MkErrorC_Check(ctx, errVal);
1764 MkErrorC_Check(ctx, errVal);
1772 MkErrorC_Check(ctx, errVal);
1780 MkErrorC_Check(ctx, errVal);
1789 MkErrorC_Check(ctx, errVal);
1798 MkErrorC_Check(ctx, errVal);
1806 MkErrorC_Check(ctx, errVal);
1813 const MK_STRN val_hdl = val.c_str();
1815 MkErrorC_Check(ctx, errVal);
1824 MkErrorC_Check(ctx, errVal);
1832 va_start (ap, printfmt);
1835 MkErrorC_Check(ctx, errVal);
1843 MkErrorC_Check(ctx, errVal);
1860 MkErrorC_Check(ctx, errVal);
1867 const MK_STRN token_hdl = token.c_str();
1869 MkErrorC_Check(ctx, errVal);
1878 MkErrorC_Check(ctx, errVal);
1885 const MK_STRN token_hdl = token.c_str();
1888 MkErrorC_Check(ctx, errVal);
1897 MkErrorC_Check(ctx, errVal);
1904 const MK_STRN token_hdl = token.c_str();
1907 MkErrorC_Check(ctx, errVal);
1916 MkErrorC_Check(ctx, errVal);
1923 const MK_STRN token_hdl = token.c_str();
1926 MkErrorC_Check(ctx, errVal);
1935 MkErrorC_Check(ctx, errVal);
1942 const MK_STRN token_hdl = token.c_str();
1945 MkErrorC_Check(ctx, errVal);
1954 MkErrorC_Check(ctx, errVal);
1961 const MK_STRN token_hdl = token.c_str();
1964 MkErrorC_Check(ctx, errVal);
1973 MkErrorC_Check(ctx, errVal);
1980 const MK_STRN token_hdl = token.c_str();
1983 MkErrorC_Check(ctx, errVal);
1991 MkErrorC_Check(ctx, errVal);
1998 const MK_STRN token_hdl = token.c_str();
1999 const MK_STRN callback_hdl = callback.c_str();
2001 MkErrorC_Check(ctx, errVal);
2009 MkErrorC_Check(ctx, errVal);
2016 const MK_STRN token_hdl = token.c_str();
2018 MkErrorC_Check(ctx, errVal);
2026 MkErrorC_Check(ctx, errVal);
2034 MkErrorC_Check(ctx, errVal);
2051 MkErrorC_Check(ctx, errVal);
2059 MkErrorC_Check(ctx, errVal);
2067 MkErrorC_Check(ctx, errVal);
2075 MkErrorC_Check(ctx, errVal);
2092 MkErrorC_Check(ctx, errVal);
2100 MkErrorC_Check(ctx, errVal);
2108 MkErrorC_Check(ctx, errVal);
2126 MkErrorC_Check(ctx, errVal);
2133 const MK_STRN token_hdl = token.c_str();
2136 MkErrorC_Check(ctx, errVal);
2145 MkErrorC_Check(ctx, errVal);
2152 const MK_STRN token_hdl = token.c_str();
2155 MkErrorC_Check(ctx, errVal);
2164 MkErrorC_Check(ctx, errVal);
2171 const MK_STRN token_hdl = token.c_str();
2174 MkErrorC_Check(ctx, errVal);
2182 MkErrorC_Check(ctx, errVal);
2189 const MK_STRN token_hdl = token.c_str();
2191 MkErrorC_Check(ctx, errVal);
2207 MkErrorC_Check(ctx, errVal);
2214 const MK_STRN token_hdl = token.c_str();
2216 MkErrorC_Check(ctx, errVal);
2225 MkErrorC_Check(ctx, errVal);
2234 MkErrorC_Check(ctx, errVal);
2241 const MK_STRN token_hdl = token.c_str();
2244 MkErrorC_Check(ctx, errVal);
2251 const MK_STRN token_hdl = token.c_str();
2254 MkErrorC_Check(ctx, errVal);
2279 const MK_STRN token_hdl = token.c_str();
2289 const MK_STRN token_hdl = token.c_str();
2300 MkErrorC_Check(ctx, errVal);
2307 const MK_STRN token_hdl = token.c_str();
2308 const MK_STRN ident_hdl = ident.c_str();
2310 MkErrorC_Check(ctx, errVal);
2318 MkErrorC_Check(ctx, errVal);
2325 const MK_STRN token_hdl = token.c_str();
2327 MkErrorC_Check(ctx, errVal);
2342 const MK_STRN token_hdl = token.c_str();
2359 const MK_STRN token_hdl = token.c_str();
2397 MkErrorC_Check(ctx, errVal);
2407 MkErrorC_Check(ctx, errVal);
2417 MkErrorC_Check(ctx, errVal);
2437 MkErrorC_Check(ctx, errVal);
2446 MkErrorC_Check(ctx, errVal);
2454 MkErrorC_Check(ctx, errVal);
2471 MkErrorC_Check(ctx, errVal);
2487 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (
MQ_LTR)(*transLIdP_inout);
2489 if (transLIdP_inout != NULL) {*transLIdP_inout = (
MQ_LTR)(transLIdP_inout_val);}
2490 MkErrorC_Check(ctx, errVal);
2491 return transLIdP_inout_val;
2498 MQ_LTR transLIdP_inout_val = transLIdP_inout == NULL ? 0 : (
MQ_LTR)(*transLIdP_inout);
2500 if (transLIdP_inout != NULL) {*transLIdP_inout = (
MQ_LTR)(transLIdP_inout_val);}
2501 MkErrorC_Check(ctx, errVal);
2502 return transLIdP_inout_val;
2512 MkErrorC_Check(ctx, errVal);
2520 MkErrorC_Check(ctx, errVal);
2528 MkErrorC_Check(ctx, errVal);
2535 if (callfunc == NULL) {callfunc = __builtin_FUNCTION();}
2537 MkErrorC_Check(ctx, errVal);
2545 MkErrorC_Check(ctx, errVal);
2552 const MK_STRN storageFile_hdl = storageFile.c_str();
2554 MkErrorC_Check(ctx, errVal);
2565 MkErrorC_Check(ctx, errVal);
2575 MkErrorC_Check(ctx, errVal);
2585 MkErrorC_Check(ctx, errVal);
2596 MkErrorC_Check(ctx, errVal);
2615 if (__retVal__L == NULL) {
2618 return (
MK_OBJ)__retVal__L;
2626 if (__retVal__L == NULL) {
2643 if (__retVal__L == NULL) {
2646 return (
MK_OBJ)__retVal__L;
MqCall_cc.hh - 25 Aug 2024 - aotto1968.
implements the ccmqmsgque API object: ConfigSetBgError
implements the ccmqmsgque API object: ConfigSetEvent
implements the ccmqmsgque API object: ConfigSetServerCleanup
implements the ccmqmsgque API object: ConfigSetServerSetup
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary … ...
data used to define a factory → C-API: libmqmsgque::MqFactoryS
MK_BUFN getBUFN(bool nullB=MK_NULL_NO) const
static MkBufferC * MkBufferC_ObjNew(MK_RT const mkrt, MK_BUF hdl)
MK_BUF getBUF(bool nullB=MK_NULL_NO) const
MK_BFLN getBFLN(bool nullB=MK_NULL_NO) const
MK_BFL getBFL(bool nullB=MK_NULL_NO) const
static MkBufferListC * MkBufferListC_ObjNew(MK_RT const mkrt, MK_BFL hdl)
MK_BUSN getBUSN(bool nullB=MK_NULL_NO) const
static MkErrorC * MkErrorC_ObjNew(MK_RT const mkrt, MK_ERR hdl)
MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
MkStringR MkStringCreate(MK_NUM len, MK_STRN str)
MK_OBJ getOBJ(bool nullB=MK_NULL_NO) const
void ErrorCheck(enum MkErrorE err, MK_STRN const caller=__builtin_FUNCTION(), MK_I32 const line=__builtin_LINE()) const
MK_OBJN getOBJN(bool nullB=MK_NULL_NO) const
MK_EXTERN MK_PTR MkSysRealloc(MK_OBJ const fmtobj, MK_PTR const buf, size_t const size)
MK_I32 MkRuntimeGetDebug(void)
MqTokenCCB MqServerSetupCCB
static MqContextC * MqContextC_ObjNew(MK_RT const mkrt, MQ_CTX hdl)
return MqContextC from LibMsgqueObject
static MK_PTR MqContextC_selfCreate(MK_RT const mkrt, MK_OBJ obj, MK_PTR const env)
MqTokenCCB MqServerCleanupCCB
MqTokenICB MqServerSetupICB
MQ_CTX getCTX(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqContextC instance
static MqContextC * MqContextC_ObjCreate(MK_RT const mkrt, MQ_CTX hdl)
MqTokenICB MqServerCleanupICB
MQ_CTXN getCTXN(bool nullB=MK_NULL_NO) const
(const) return the LibMsgqueObject from current MqContextC instance
MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
void ClassIdentSet(MK_STRN ident)
C++: ctx.ClassIdentSet(MK_STRN ident) → C-API link the MqContextC to a new MqFactoryC identifie...
void ClassFactorySet(MqFactoryC *item)
C++: ctx.ClassFactorySet(MqFactoryC* item) → C-API link the MqContextC to a new MqFactoryC
MK_STRN ClassOriginalIdentGet() const
C++: MK_STRN ctx.ClassOriginalIdentGet() → C-API get the libmqmsgque::MqFactoryS::originalIdent...
MK_STRN ClassIdentGet() const
C++: MK_STRN ctx.ClassIdentGet() → C-API get the application-identification …
MqFactoryC * ClassFactoryGet() const
C++: MqFactoryC* ctx.ClassFactoryGet() → C-API get the MqFactoryC used by the MqContextC
#define MqClassFactorySet(...)
MQ_EXTERN MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the libmqmsgque::MqFactoryS::originalIdent from the MqContextC
MQ_EXTERN MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the MqFactoryC used by the MqContextC
#define MqClassIdentSet(...)
MQ_EXTERN MK_STRN MqClassIdentGet(MQ_CTXN const ctx) MK_ATTR_HDL
get the application-identification …
static MqContextC * HandleResolve(MK_HDL netHdl)
C++: [static] MqContextC* MqContextC::HandleResolve(MK_HDL netHdl) → C-API Handle-Resolve-Slot -...
MqContextC * Prev()
C++: MqContextC* ctx.Prev() → C-API get previous instance from linked-list of MqContextS type
static MqContextC * Instances()
C++: [static] MqContextC* MqContextC::Instances() → C-API get head-instance from linked-list of ...
MqContextC * Next()
C++: MqContextC* ctx.Next() → C-API get next instance from linked-list of MqContextS type
static MqContextC * GetNull()
C++: [static] MqContextC* MqContextC::GetNull() → C-API Null-Slot - return a MqContextC typed NU...
#define MqContextHandleResolve(...)
MK_ATTR_HDL MQ_CTX MqContextPrev(MQ_CTX const ctx)
get previous instance from linked-list of MqContextS type
#define MqContextInstances()
MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
MK_ATTR_HDL MQ_CTX MqContextNext(MQ_CTX const ctx)
get next instance from linked-list of MqContextS type
MqStatusIsEF ConfigGetStatusIs()
C++: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API return the libmqmsgque::MqContextS::statusIs ...
MqStartE ConfigGetStartAs()
C++: MqStartE ctx.ConfigGetStartAs() → C-API return the libmqmsgque::MqConfigS::startAs value
MK_STRN ConfigGetStorage() const
C++: MK_STRN ctx.ConfigGetStorage() → C-API get the storage of the context object
MK_I32 ConfigGetPkgsize() const
C++: MK_I32 ctx.ConfigGetPkgsize() → C-API get the maximun size of a BDY package
MQ_SOCK_HDL ConfigGetIoPipe()
C++: MQ_SOCK_HDL ctx.ConfigGetIoPipe() → C-API return the libmqmsgque::MqIoPipeConfigS
MK_TIME_T ConfigGetTimeout() const
C++: MK_TIME_T ctx.ConfigGetTimeout() → C-API get the timeout value of the context object
MkBufferListC * ConfigGetIoTcpL()
C++: MkBufferListC* ctx.ConfigGetIoTcpL() → C-API get the configuration-data of the tcp-client-...
void ConfigSetConfigFile(MK_STRN filename)
C++: ctx.ConfigSetConfigFile(MK_STRN filename) → C-API set the config-file and parse for well-k...
MK_I32 ConfigGetBuffersize() const
C++: MK_I32 ctx.ConfigGetBuffersize() → C-API get the minimum of the read/send buffersize of th...
MK_BOOL ConfigGetIsParent()
C++: MK_BOOL ctx.ConfigGetIsParent() → C-API does the context object is a parent ?...
MK_STRN ConfigGetPostfix() const
C++: MK_STRN ctx.ConfigGetPostfix() → C-API get the libmqmsgque::MqConfigS::postfix
MK_BOOL ConfigGetIsString()
C++: MK_BOOL ctx.ConfigGetIsString() → C-API does the context object is using the string-mode ?
MK_STRN ConfigGetName() const
C++: MK_STRN ctx.ConfigGetName() → C-API get the name of the context object
MqIdentE ConfigGetIdentFrom()
C++: MqIdentE ctx.ConfigGetIdentFrom() → C-API get the libmqmsgque::MqConfigS::identFrom
std::tuple< MK_STRN, MK_STRN, MK_STRN, MK_STRN > ConfigGetIoTcp()
C++: {host:MK_STRN port:MK_STRN myhost:MK_STRN myport:MK_STRN} ctx.ConfigGetIoTcp() → C-API get...
MK_BOOL ConfigGetIsServer()
C++: MK_BOOL ctx.ConfigGetIsServer() → C-API does the context object is a server ?
MK_STRN ConfigGetPrefix() const
C++: MK_STRN ctx.ConfigGetPrefix() → C-API get the libmqmsgque::MqConfigS::prefix
MK_STRN ConfigGetIoUds() const
C++: MK_STRN ctx.ConfigGetIoUds() → C-API return the libmqmsgque::MqIoUdsConfigS
MK_ATTR_HDL bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
MK_ATTR_HDL MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
MK_ATTR_HDL enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the libmqmsgque::MqConfigS::identFrom
#define MqConfigSetConfigFile(...)
MQ_EXTERN enum MkErrorE MqConfigGetIoTcp(MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out) MK_ATTR_HDL
get the configuration-data of the tcp-client-server-link …
MK_ATTR_HDL MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::postfix
MK_ATTR_HDL bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
MQ_EXTERN enum MkErrorE MqConfigGetIoTcpL(MQ_CTX const ctx, MK_BFL *vals_out) MK_ATTR_HDL
get the configuration-data of the tcp-client-server-link as MkBufferListC …
MK_ATTR_HDL MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
MK_ATTR_HDL MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the libmqmsgque::MqIoUdsConfigS
MK_ATTR_HDL MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the libmqmsgque::MqIoPipeConfigS
MK_ATTR_HDL enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the libmqmsgque::MqConfigS::startAs value
MK_ATTR_HDL MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
MK_ATTR_HDL MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the libmqmsgque::MqConfigS::prefix
MK_ATTR_HDL MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
MK_ATTR_HDL MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
MK_ATTR_HDL bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the libmqmsgque::MqConfigS::parent att...
MK_ATTR_HDL enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the libmqmsgque::MqContextS::statusIs value
void ConfigSetServerCleanup(MqServerCleanupICB callback=NULL)
C++: ctx.ConfigSetServerCleanup(MqServerCleanupICB MqServerCleanupCCB MqServerCleanupIF* callback = ...
void ConfigSetEvent(MqEventICB callback=NULL)
C++: ctx.ConfigSetEvent(MqEventICB MqEventCCB MqEventIF* callback = NULL) → C-API set the libmq...
void ConfigSetServerSetup(MqServerSetupICB callback=NULL)
C++: ctx.ConfigSetServerSetup(MqServerSetupICB MqServerSetupCCB MqServerSetupIF* callback = NULL) →...
void ConfigSetBgError(MqBgErrorICB callback=NULL)
C++: ctx.ConfigSetBgError(MqBgErrorICB MqBgErrorCCB MqBgErrorIF* callback = NULL) → C-API set t...
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
void ConfigReset()
C++: ctx.ConfigReset() → C-API clean the libmqmsgque::MqContextS::config data
#define MqConfigReset(...)
void ConfigSetBuffersize(MK_I32 data)
C++: ctx.ConfigSetBuffersize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::buffersize ...
void ConfigSetPrefix(MK_STRN data)
C++: ctx.ConfigSetPrefix(MK_STRN data) → C-API set the server-part (1) of the application-ide...
MK_BOOL ConfigCheckStartAs(MqStartE data)
C++: MK_BOOL ctx.ConfigCheckStartAs(MqStartE data) → C-API check if libmqmsgque::MqConfigS::sta...
void ConfigSetPostfix(MK_STRN data)
C++: ctx.ConfigSetPostfix(MK_STRN data) → C-API set the client-part (2) of the application-id...
void ConfigSetIgnoreExit(MK_BOOL data)
C++: ctx.ConfigSetIgnoreExit(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::ignoreExit va...
void ConfigSetIdentFrom(MqIdentE data)
C++: ctx.ConfigSetIdentFrom(MqIdentE data) → C-API set the libmqmsgque::MqConfigS::identFrom va...
void ConfigSetStartAsString(MK_STRN data)
C++: ctx.ConfigSetStartAsString(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::startAs v...
void ConfigSetAllDebug(MK_I32 data)
C++: ctx.ConfigSetAllDebug(MK_I32 data) → C-API set the MkRuntimeS::debug value
void ConfigSetStartAs(MqStartE data)
C++: ctx.ConfigSetStartAs(MqStartE data) → C-API set the libmqmsgque::MqConfigS::startAs value
void ConfigSetDaemon(MK_STRN pidfile)
C++: ctx.ConfigSetDaemon(MK_STRN pidfile) → C-API start the server-context as daemon …
void ConfigSetPkgsize(MK_I32 data)
C++: ctx.ConfigSetPkgsize(MK_I32 data) → C-API set the libmqmsgque::MqIoConfigS::pkgsize value
void ConfigSetStorage(MK_STRN data)
C++: ctx.ConfigSetStorage(MK_STRN data) → C-API set the Storage value and cleanup old value
void ConfigSetIsString(MK_BOOL data)
C++: ctx.ConfigSetIsString(MK_BOOL data) → C-API set the libmqmsgque::MqConfigS::native value '...
void ConfigSetName(MK_STRN data)
C++: ctx.ConfigSetName(MK_STRN data) → C-API set the libmqmsgque::MqConfigS::dispname value and...
void ConfigSetIoTcp(MK_STRN host=NULL, MK_STRN port=NULL, MK_STRN myhost=NULL, MK_STRN myport=NULL)
C++: ctx.ConfigSetIoTcp(MK_STRN host = NULL, MK_STRN port = NULL, MK_STRN myhost = NULL,...
void ConfigSetIoUds(MK_STRN file)
C++: ctx.ConfigSetIoUds(MK_STRN file) → C-API configure a context to use a uds-client-server-...
void ConfigSetTimeout(MK_TIME_T data)
C++: ctx.ConfigSetTimeout(MK_TIME_T data) → C-API set the libmqmsgque::MqIoConfigS::timeout val...
void ConfigSetIoPipe(MQ_SOCK_HDL fh)
C++: ctx.ConfigSetIoPipe(MQ_SOCK_HDL fh) → C-API set the pipe configuration data …
void ConfigSetIsServer(MK_BOOL data)
C++: ctx.ConfigSetIsServer(MK_BOOL data) → C-API set the libmqmsgque::MqSetupS::isServer value
#define MqConfigSetDaemon(...)
#define MqConfigSetPrefix(...)
MQ_EXTERN enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::startAs value using string default, thread, fork or spawn
#define MqConfigSetIoPipe(...)
MQ_EXTERN void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::identFrom value
#define MqConfigSetIoTcp(...)
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
MQ_EXTERN void MqConfigSetIsServer(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqSetupS::isServer value
MQ_EXTERN void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::buffersize value
MQ_EXTERN void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::pkgsize value
MQ_EXTERN void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data) MK_ATTR_HDL
set the libmqmsgque::MqIoConfigS::timeout value
#define MqConfigSetIoUds(...)
MQ_EXTERN enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::startAs value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
MQ_EXTERN void MqConfigSetIsString(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetStorage(...)
MQ_EXTERN bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data) MK_ATTR_HDL
check if libmqmsgque::MqConfigS::startAs can be set to data
MQ_EXTERN void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data) MK_ATTR_HDL
set the libmqmsgque::MqSetupS::ignoreExit value
void EnvProtect()
C++: ctx.EnvProtect() → C-API protect the service-environment
void EnvRestore()
C++: ctx.EnvRestore() → C-API restore the service-environment
#define MqEnvProtect(...)
MQ_EXTERN void MqEnvRestore(MQ_CTX ctx) MK_ATTR_HDL
restore the service-environment
MkErrorC * ErrorFORMAT() const
C++: MkErrorC* fmtobj.ErrorFORMAT() → C-API helper used to access MkErrorDEFAULT from MqContext...
MkErrorE ErrorCopy(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorCopy(const MqContextC* sourceCtx) → C-API copy a MkErrorS from the...
MkErrorE ErrorMove(const MqContextC *sourceCtx) const
C++: MkErrorE targetCtx.ErrorMove(const MqContextC* sourceCtx) → C-API move a MkErrorS from the...
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
void SendVL2(MK_STRN cstr, va_list var_list)
C++: ctx.SendVL2(MK_STRN cstr, va_list var_list) → C-API A version of MqSend with va_list suppo...
void LinkCreate(MkBufferListC *args=NULL)
C++: ctx.LinkCreate(MkBufferListC* args = NULL) → C-API make ctx to a parent-context and setup ...
MK_BOOL LinkIsParent()
C++: MK_BOOL ctx.LinkIsParent() → C-API is the context a parent-context? …
void LinkDelete()
C++: ctx.LinkDelete() → C-API close the client-server-link …
void LinkShutdown()
C++: ctx.LinkShutdown() → C-API shutdown the communication with a server
MK_STRN LinkGetTargetIdent()
C++: MK_STRN ctx.LinkGetTargetIdent() → C-API get the ident of the link-target …
MK_BOOL LinkIsConnected()
C++: MK_BOOL ctx.LinkIsConnected() → C-API is the context connected? …
MqContextC * LinkGetParent()
C++: MqContextC* ctx.LinkGetParent() → C-API get the initial parent-context from a client/serve...
void LinkConnect()
C++: ctx.LinkConnect() → C-API re-connect a client-server-link after a server crash or a networ...
MK_NUM LinkGetCtxId()
C++: MK_NUM ctx.LinkGetCtxId() → C-API get an identifier which is unique per parent-or-child-co...
void LinkCreateChild(MqContextC *parent, MkBufferListC *args=NULL)
C++: ctx.LinkCreateChild(MqContextC* parent, MkBufferListC* args = NULL) → C-API make a context...
#define MqLinkShutdown(...)
#define MqLinkCreateChild(...)
MK_NUM MqLinkGetCtxId(MQ_CTX const ctx)
get an identifier which is unique per parent-or-child-context …
bool MqLinkIsParent(MQ_CTX const ctx)
is the context a parent-context? …
MQ_CTX MqLinkGetParent(MQ_CTX const ctx)
get the initial parent-context from a client/server link …
#define MqLinkDelete(...)
#define MqLinkCreate(...)
MQ_EXTERN bool MqLinkIsConnected(MQ_CTX const ctx) MK_ATTR_HDL
is the context connected? …
MK_STRN MqLinkGetTargetIdent(MQ_CTX const ctx)
get the ident of the link-target …
#define MqLinkConnect(...)
MK_STRN LogParentOrChild() const
C++: MK_STRN ctx.LogParentOrChild() → C-API is ctx a PARENT or a CHILD ? …
void LogShort(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0, MK_STRN label=NULL) const
C++: ctx.LogShort(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
void LogLink(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogLink(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNC...
void LogType(MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogType(MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION()...
void LogEnv(MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogEnv(MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION(),...
void Log(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.Log(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUNCTION...
void LogConfig(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogConfig(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FU...
void LogSetup(const MkObjectC *fmtobj=NULL, MK_DBG debug=0, MK_STRN callfunc=__builtin_FUNCTION(), MK_I32 lvl=0) const
C++: ctx.LogSetup(const MkObjectC* fmtobj = NULL, MK_DBG debug = 0, MK_STRN callfunc = __builtin_FUN...
MK_STRN LogServerOrClient() const
C++: MK_STRN ctx.LogServerOrClient() → C-API is ctx a SERVER or a CLIENT ? …
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
MK_ATTR_HDL MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
#define MqContextLog(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
MK_ATTR_HDL MK_STRN MqLogParentOrChild(MQ_CTXN ctx)
is ctx a PARENT or a CHILD ? …
void ProcessEvent(MqWaitOnEventE wait=MQ_WAIT_NO, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.ProcessEvent(MqWaitOnEventE wait = MQ_WAIT_NO, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C...
MkBufferC * GetBuffer()
C++: MkBufferC* ctx.GetBuffer() → C-API get the libmqmsgque::MqContextS::ctxbuf object
MqContextC * GetRoot()
C++: MqContextC* ctx.GetRoot() → C-API get the Root (toplevel initial context)
MK_STRN ToString() const
C++: MK_STRN ctx.ToString() → C-API String-Slot - returns the string representation of the inst...
void Exit(MK_STRN callfunc=__builtin_FUNCTION(), MK_STRN callfile=__builtin_FILE(), MK_I32 callline=__builtin_LINE())
C++: ctx.Exit(MK_STRN callfunc = __builtin_FUNCTION(), MK_STRN callfile = __builtin_FILE(),...
#define MqProcessEvent(...)
#define MqContextGetBuffer(...)
#define MqContextToString(...)
MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
void ProxyForward(MqContextC *targetCtx, MqDumpC *dump=NULL, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: sourceCtx.ProxyForward(MqContextC* targetCtx, MqDumpC* dump = NULL, MK_TIME_T timeout = MK_TIME...
void ProxyItem(MqContextC *targetCtx)
C++: sourceCtx.ProxyItem(MqContextC* targetCtx) → C-API Copy a single-data-item from the source...
#define MqProxyForward(...)
MK_BNP ReadBinaryR()
C++: MK_BNP ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
std::string ReadStringR()
C++: std::string ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
MK_HDL ReadHDL()
C++: MK_HDL ctx.ReadHDL() → C-API read the handle from the read-data-package
MK_BNP ReadBIN()
C++: doc_mq_cc_ReadBIN → C-API generic function to read an libmkkernel::MK_BIN object from the r...
MK_BOL ReadBOL()
C++: doc_mq_cc_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
MkBufferC * ReadBUF()
C++: MkBufferC* ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
MkBufferListC * ReadBFL()
C++: MkBufferListC* ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in ...
MkBufferListC * ReadALL(MkBufferListC *val_inout=NULL)
C++: MkBufferListC* ctx.ReadALL(MkBufferListC* val_inout = NULL) → C-API get a temporary MkBuff...
MK_I32 ReadI32()
C++: doc_mq_cc_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I64 ReadI64()
C++: doc_mq_cc_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_LONG ReadLONG()
C++: MK_LONG ctx.ReadLONG() → C-API read the long native object from the read-data-package
MK_I16 ReadI16()
C++: doc_mq_cc_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_FLT ReadFLT()
C++: doc_mq_cc_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_DBL ReadDBL()
C++: doc_mq_cc_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_STRN ReadSTR()
C++: doc_mq_cc_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
MK_I8 ReadI8()
C++: doc_mq_cc_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
#define MqReadBinaryR(...)
#define MqReadStringR(...)
void ReadT_END()
C++: ctx.ReadT_END() → C-API finish to extract a longterm-transaction-item from the read-data-p...
void ReadL_END()
C++: ctx.ReadL_END() → C-API finish to extract a list-items from the read-data-package....
void ReadT_START()
C++: ctx.ReadT_START() → C-API start to extract a longterm-transaction-item from the read-data-...
void ReadL_START(MkBufferC *buf=NULL)
C++: ctx.ReadL_START(MkBufferC* buf = NULL) → C-API start to extract a list-items from the read...
#define MqReadT_START(...)
#define MqReadL_START(...)
MK_BOOL ReadItemExists()
C++: MK_BOOL ctx.ReadItemExists() → C-API check if an item exists in the read-data-package …
void ReadUndo()
C++: ctx.ReadUndo() → C-API undo the last MqContextC READ API function call …
MkTypeE ReadGetNextType()
C++: MkTypeE ctx.ReadGetNextType() → C-API get the type (MkTypeE) of the next Item in the read-...
MK_NUM ReadGetNumItems()
C++: MK_NUM ctx.ReadGetNumItems() → C-API get the number of items left in the read-data-package...
MQ_EXTERN bool MqReadItemExists(MQ_CTX const ctx) MK_ATTR_HDL
check if an item exists in the read-data-package …
MQ_EXTERN MK_NUM MqReadGetNumItems(MQ_CTX const ctx) MK_ATTR_HDL
get the number of items left in the read-data-package …
MQ_EXTERN enum MkTypeE MqReadGetNextType(MQ_CTX const ctx) MK_ATTR_HDL
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
MK_STRN RouteGetPath()
C++: MK_STRN ctx.RouteGetPath() → C-API return the absolut route-connection-string up to the cu...
MqContextC_A RouteResolve(MK_STRN ident, MK_NUM retnum=-1)
C++: MqContextC_A ctx.RouteResolve(MK_STRN ident, MK_NUM retnum = -1) → C-API return a list of ...
MkBufferListC * RouteGetTree()
C++: MkBufferListC* ctx.RouteGetTree() → C-API create an overview about all available routing-t...
void RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteCreate(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API create/...
void RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite=false)
C++: ctx.RouteDelete(MK_STRN route, MK_STRN service, MK_BOOL overwrite = false) → C-API delete ...
void RouteTraverse(MK_STRN service, MkBufferListC *args=NULL)
C++: ctx.RouteTraverse(MK_STRN service, MkBufferListC* args = NULL) → C-API traverse a tree dow...
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
void SendBOL(MK_BOL val)
C++: doc_mq_cc_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendVL(MK_FST printfmt, va_list var_list)
C++: ctx.SendVL(MK_FST printfmt, va_list var_list) → C-API append a vararg string as va_list to...
void SendStringR(const std::string &val)
C++: ctx.SendStringR(const std::string& val) → C-API MqContextC - append a native PRIMITIVE T...
void SendBFL(const MkBufferListC *val)
C++: ctx.SendBFL(const MkBufferListC* val) → C-API append a MkBufferListC object to the send-da...
void SendBinaryR(MK_BNP val)
C++: ctx.SendBinaryR(MK_BNP val) → C-API append a MkBinaryR object to the send-data-package....
void SendBUS_FLAT(const MkBufferStreamC *val)
C++: ctx.SendBUS_FLAT(const MkBufferStreamC* val) → C-API append a MkBufferStreamC object to th...
void SendLONG(MK_LONG val)
C++: ctx.SendLONG(MK_LONG val) → C-API send the long native object to the send-data-package
void SendDBL(MK_DBL val)
C++: doc_mq_cc_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI64(MK_I64 val)
C++: doc_mq_cc_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendBIN(MK_BNP val)
C++: doc_mq_cc_SendBIN → C-API append a libmkkernel::MK_BIN object to the send-data-package....
void SendHDL(MK_HDL val)
C++: ctx.SendHDL(MK_HDL val) → C-API send the handle to the send-data-package
void SendL_FLAT(const MkBufferListC *val)
C++: ctx.SendL_FLAT(const MkBufferListC* val) → C-API append a MkBufferListC object as flat lis...
void SendI16(MK_I16 val)
C++: doc_mq_cc_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendLTR(MQ_LTR transLId)
SendLTR
void SendFLT(MK_FLT val)
C++: doc_mq_cc_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendV(MK_FST printfmt,...)
C++: ctx.SendV(MK_FST printfmt, ... ) → C-API append a vararg string to the send-data-package o...
void SendBUF(const MkBufferC *val)
C++: ctx.SendBUF(const MkBufferC* val) → C-API append a MkBufferC object to the send-data-packa...
void SendI8(MK_I8 val)
C++: doc_mq_cc_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-data...
void SendSTR(MK_STRN val)
C++: doc_mq_cc_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
void SendI32(MK_I32 val)
C++: doc_mq_cc_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-d...
#define MqSendStringR(...)
#define MqSendL_FLAT(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
void SendSTART()
C++: ctx.SendSTART() → C-API initialize the send-data-package. …
void SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_CALLBACK(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
void SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_WAIT(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API finish ...
void SendSYNC()
C++: ctx.SendSYNC() → C-API garantee that all pending asynchronous-service-calls are processed....
void SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_TRANSACTION(MQ_TOK token, MQ_TOK callback, MK_TIME_T timeout = MK_TIMEOUT_DEFAU...
void SendEND(MQ_TOK token, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND(MQ_TOK token, MK_TIME_T timeout = MK_TIMEOUT_DEFAULT) → C-API MqContextC - fin...
void SendEND_AND_SUB(MQ_TOK token, MqServiceICB callback, MK_TIME_T timeout=MK_TIMEOUT_DEFAULT)
C++: ctx.SendEND_AND_SUB(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback,...
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
void SendL_END()
C++: ctx.SendL_END() → C-API finish to append an embedded body-list-item to the send-data-packa...
void SendT_START()
C++: ctx.SendT_START() → C-API open a longterm-transaction-item …
void SendL_START()
C++: ctx.SendL_START() → C-API start to append an embedded body-list-item to the send-data-pack...
void SendT_END()
C++: ctx.SendT_END() → C-API closed a longterm-transaction-item …
#define MqSendL_START(...)
#define MqSendT_START(...)
void SendRETURN_SUB()
C++: ctx.SendRETURN_SUB() → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB …
void SendERROR()
C++: ctx.SendERROR() → C-API send the data from the MkErrorC to the link target ....
void SendRETURN()
C++: ctx.SendRETURN() → C-API MqContextC - finish the send-data-block on the server and optiona...
#define MqSendRETURN_SUB(...)
#define MqSendRETURN(...)
MK_BOOL ServiceIsTransaction()
C++: MK_BOOL ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a ...
void ServiceProxyCtx(MQ_TOK token, MqContextC *target)
C++: ctx.ServiceProxyCtx(MQ_TOK token, MqContextC* target) → C-API same as MqServiceProxy but u...
MK_BOOL ServiceProxyCtxExists(MQ_TOK token, MqContextC *target)
C++: MK_BOOL ctx.ServiceProxyCtxExists(MQ_TOK token, MqContextC* target) → C-API check if servi...
void ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident)
C++: ctx.ServiceProxyRoundRobin(MQ_TOK token, MK_STRN ident) → C-API create a proxy-service usi...
void ServiceCreate(MQ_TOK token, MqServiceICB callback)
C++: ctx.ServiceCreate(MQ_TOK token, MqServiceICB MqServiceCCB MqServiceIF* callback) ...
void 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 t...
void ServiceStorage(MQ_TOK token)
C++: ctx.ServiceStorage(MQ_TOK token) → C-API setup a service listen on a MqContextC_ServiceApi...
MK_BOOL ServiceTokenExists(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenExists(MQ_TOK token) → C-API check if the MqContextC_ServiceApi_Id...
void ServiceDelete(MQ_TOK token)
C++: ctx.ServiceDelete(MQ_TOK token) → C-API delete a service. …
MK_BOOL ServiceTokenCheck(MQ_TOK token)
C++: MK_BOOL ctx.ServiceTokenCheck(MQ_TOK token) → C-API in an ongoing-service-call check if th...
MQ_TOK ServiceTokenGet()
C++: MQ_TOK ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContextC...
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
MQ_EXTERN bool MqServiceProxyCtxExists(MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
check if service who belongs to token is a proxy-service
#define MqServiceCreate(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
MK_ATTR_HDL bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceProxy(...)
MQ_EXTERN bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token) MK_ATTR_HDL
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
MQ_EXTERN bool MqServiceTokenCheck(MQ_CTX const ctx, MQ_TOK const token) MK_ATTR_HDL
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
#define MqServiceProxyRoundRobin(...)
MQ_EXTERN MQ_TOK MqServiceTokenGet(MQ_CTX const ctx) MK_ATTR_HDL
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
#define MqServiceDelete(...)
MK_BOOL SlaveCheck(MQ_SLAVE_ID id) const
C++: MK_BOOL ctx.SlaveCheck(MQ_SLAVE_ID id) → C-API check if slave-id is valid
MqContextC * SlaveGetProxy(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGetProxy(MQ_SLAVE_ID id) → C-API on slave return the master and on ma...
void SlaveCreate(MQ_SLAVE_ID id, MqContextC *slave)
C++: ctx.SlaveCreate(MQ_SLAVE_ID id, MqContextC* slave) → C-API create a master/slave link betw...
MqContextC * SlaveGet(MQ_SLAVE_ID id)
C++: MqContextC* ctx.SlaveGet(MQ_SLAVE_ID id) → C-API get the slave-context from a master-conte...
void SlaveDelete(MQ_SLAVE_ID id)
C++: ctx.SlaveDelete(MQ_SLAVE_ID id) → C-API Delete a slave object from a master/slave link ide...
MqContextC * SlaveGetFilter()
C++: MqContextC* ctx.SlaveGetFilter() → C-API get the filter-ctx or the master-ctx …
MK_BOOL SlaveIs() const
C++: MK_BOOL ctx.SlaveIs() → C-API is the context a slave-context ? …
MqContextC * SlaveGetMaster()
C++: MqContextC* ctx.SlaveGetMaster() → C-API opposite function of MqSlaveGetFilter
void SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct="WORKER", MkBufferListC *args=NULL)
C++: ctx.SlaveWorker(MQ_SLAVE_ID id, MK_STRN fct = "WORKER", MkBufferListC* args = NULL) → C-API ...
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
bool MqSlaveIs(MQ_CTXN const ctx)
is the context a slave-context ? …
#define MqSlaveGetFilter(...)
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
MK_I32 StorageErrCnt(MQ_LTR transLId)
C++: MK_I32 ctx.StorageErrCnt(MQ_LTR transLId) → C-API increment and return the database row-er...
void StorageClose()
C++: ctx.StorageClose() → C-API close the storage. …
void StorageOpen(MK_STRN storageFile)
C++: ctx.StorageOpen(MK_STRN storageFile) → C-API switch to a file-based-transaction-database …
MQ_LTR StorageDelete(MQ_LTR *transLIdP_inout=NULL)
C++: MQ_LTR ctx.StorageDelete(MQ_LTR *transLIdP_inout = NULL) → C-API delete the storage-row id...
std::tuple< MqContextC *, MQ_LTR > StorageResolve()
C++: {otherCtxP:MqContextC* otherLIdP:MQ_LTR} ctx.StorageResolve() → C-API extract the context-...
MQ_LTR StorageExport()
C++: MQ_LTR ctx.StorageExport() → C-API export the read-data-package into the STORAGE …
void StorageDecrRef(MQ_LTR transLId)
C++: ctx.StorageDecrRef(MQ_LTR transLId) → C-API decrease the internal refCount lock of the dat...
MQ_LTR StorageCount()
C++: MQ_LTR ctx.StorageCount() → C-API count the number of storage-rows …
MQ_LTR StorageImport(MQ_LTR *transLIdP_inout=NULL)
C++: MQ_LTR ctx.StorageImport(MQ_LTR *transLIdP_inout = NULL) → C-API import the storage-packag...
void StorageLog(MK_STRN callfunc=__builtin_FUNCTION())
C++: ctx.StorageLog(MK_STRN callfunc = __builtin_FUNCTION()) → C-API log the storage the status...
void StorageIncrRef(MQ_LTR transLId)
C++: ctx.StorageIncrRef(MQ_LTR transLId) → C-API increase the internal refCount lock of the dat...
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
static MK_OBJ CTOR(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
static MqContextC * Create(MqContextC *tmpl=NULL)
C++: [constructor,static] MqContextC* MqContextC::Create(MqContextC* tmpl = NULL) → C-API create...
#define MqContextCreate(...)
MQ_DMP getDMP(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqDumpC instance
static MqFactoryC * MqFactoryC_ObjNew(MK_RT const mkrt, MQ_FCT hdl)
return MqFactoryC from LibMsgqueObject
MQ_FCT getFCT(bool nullB=MK_NULL_NO) const
return the LibMsgqueObject from current MqFactoryC instance
MqIdentE
identify the application using prefix (default) or factory …
MqWaitOnEventE
wait for an event? …
MqStatusIsEF
Information about how the context was created.
MqStartE
User preferences on HOWTO start a new entity.
MK_NUM MQ_SLAVE_ID
a slave identiver
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
std::pair< MK_SIZE, MK_BINN > MK_BNP
namespace for the CcMqMsgque "C++"-API
PUBLIC data structure for the ccmqmsgque-specific-data → C-API: libmqmsgque::MqContextS
static enum MkErrorE Call(MQ_SERVICE_CALL_ARGS)
static MK_CBP Create(MK_RT const mkrt, MqContextC::MqTokenICB const callback, MqContextC *self=NULL)
static void Copy(MQ_SERVICE_COPY_ARGS)
static void Free(MQ_SERVICE_FREE_ARGS)
array of MqContextC instances
PUBLIC data structure for the ccmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a ccmqmsgque data package as binary …
data used to define a factory