theLink 10.0
Loading...
Searching...
No Matches
csmqmsgque.MqContextC Class Reference

MqContextC - the class known as ctx or context is the application-handle of the application-server and also the main data-handleMore...

+ Inheritance diagram for csmqmsgque.MqContextC:
+ Collaboration diagram for csmqmsgque.MqContextC:

Classes

struct  MqCall
 

Public Member Functions

delegate void MqServiceICB ()
 implements the csmqmsgque API object: public version from MqTokenF as method
 
delegate void MqServiceCCB (MqContextC ctx)
 implements the csmqmsgque API object: public version from MqTokenF as static
 
new MqContextC Next ()
  C#: MqContextC ctx.Next() C-API
get next instance from linked-list of MqContextS type
 
new MqContextC Prev ()
  C#: MqContextC ctx.Prev() C-API
get previous instance from linked-list of MqContextS type
 
MqFactoryC ClassFactoryGet ()
  C#: MqFactoryC ctx.ClassFactoryGet() C-API
get the MqFactoryC used by the MqContextC
 
void ClassFactorySet (MqFactoryC item)
  C#: ctx.ClassFactorySet(MqFactoryC item) C-API
link the MqContextC to a new MqFactoryC
 
string ClassIdentGet ()
  C#: string ctx.ClassIdentGet() C-API
get the application-identification
 
void ClassIdentSet (string ident)
  C#: ctx.ClassIdentSet(string ident) C-API
link the MqContextC to a new MqFactoryC identified by ident
 
string ClassOriginalIdentGet ()
  C#: string ctx.ClassOriginalIdentGet() C-API
get the MqFactoryS.originalIdent from the MqContextC
 
MkBufferListC ConfigGetIoTcpL ()
  C#: MkBufferListC ctx.ConfigGetIoTcpL() C-API
get the configuration-data of the tcp-client-server-link as MkBufferListC
 
int ConfigGetBuffersize ()
  C#: int ctx.ConfigGetBuffersize() C-API
get the minimum of the read/send buffersize of the socket
 
MqIdentE ConfigGetIdentFrom ()
  C#: MqIdentE ctx.ConfigGetIdentFrom() C-API
get the MqConfigS.identFrom
 
int ConfigGetIoPipe ()
  C#: int ctx.ConfigGetIoPipe() C-API
return the MqIoPipeConfigS
 
string ConfigGetIoUds ()
  C#: string ctx.ConfigGetIoUds() C-API
return the MqIoUdsConfigS
 
bool ConfigGetIsParent ()
  C#: bool ctx.ConfigGetIsParent() C-API
does the context object is a parent ? An objext is a parent id the MqConfigS.parent attribute is null
 
bool ConfigGetIsServer ()
  C#: bool ctx.ConfigGetIsServer() C-API
does the context object is a server ?
 
bool ConfigGetIsString ()
  C#: bool ctx.ConfigGetIsString() C-API
does the context object is using the string-mode ?
 
string ConfigGetName ()
  C#: string ctx.ConfigGetName() C-API
get the name of the context object
 
int ConfigGetPkgsize ()
  C#: int ctx.ConfigGetPkgsize() C-API
get the maximun size of a BDY package
 
string ConfigGetPostfix ()
  C#: string ctx.ConfigGetPostfix() C-API
get the MqConfigS.dispPostfix
 
string ConfigGetPrefix ()
  C#: string ctx.ConfigGetPrefix() C-API
get the MqConfigS.dispPrefix
 
MqStartE ConfigGetStartAs ()
  C#: MqStartE ctx.ConfigGetStartAs() C-API
return the MqConfigS.startAs value
 
MqStatusIsEF ConfigGetStatusIs ()
  C#: MqStatusIsEF ctx.ConfigGetStatusIs() C-API
return the MqContextS.statusIs value
 
string ConfigGetStorage ()
  C#: string ctx.ConfigGetStorage() C-API
get the storage of the context object
 
long ConfigGetTimeout ()
  C#: long ctx.ConfigGetTimeout() C-API
get the timeout value of the context object
 
void ConfigSetConfigFile (string filename)
  C#: ctx.ConfigSetConfigFile(string filename) C-API
set the config-file and parse for well-known config-items
 
List< object > ConfigGetIoTcp ()
  C#: {host:string port:string myhost:string myport:string} ctx.ConfigGetIoTcp() C-API
get the configuration-data of the tcp-client-server-link
 
void ConfigReset ()
  C#: ctx.ConfigReset() C-API
clean the MqContextS.config data
 
bool ConfigCheckStartAs (MqStartE data)
  C#: bool ctx.ConfigCheckStartAs(MqStartE data) C-API
check if MqConfigS.startAs can be set to data
 
void ConfigSetAllDebug (int data)
  C#: ctx.ConfigSetAllDebug(int data) C-API
set the MkRuntimeS::debug value
 
void ConfigSetBuffersize (int data)
  C#: ctx.ConfigSetBuffersize(int data) C-API
set the MqIoConfigS.buffersize value
 
void ConfigSetDaemon (string pidfile)
  C#: ctx.ConfigSetDaemon(string pidfile) C-API
start the server-context as daemon …
 
void ConfigSetIdentFrom (MqIdentE data)
  C#: ctx.ConfigSetIdentFrom(MqIdentE data) C-API
set the MqConfigS.identFrom value
 
void ConfigSetIgnoreExit (bool data)
  C#: ctx.ConfigSetIgnoreExit(bool data) C-API
set the MqSetupS.ignoreExit value
 
void ConfigSetIoPipe (int fh)
  C#: ctx.ConfigSetIoPipe(int fh) C-API
set the pipe configuration data …
 
void ConfigSetIoTcp (string host=null, string port=null, string myhost=null, string myport=null)
  C#: ctx.ConfigSetIoTcp(string host = null, string port = null, string myhost = null, string myport = null) C-API
configure a context to use a tcp-client-server-link
 
void ConfigSetIoTcp (MkBufferListC vals)
  C#: ctx.ConfigSetIoTcp(MkBufferListC vals) C-API
configure a context to use a tcp-client-server-link
 
void ConfigSetIoUds (string file)
  C#: ctx.ConfigSetIoUds(string file) C-API
configure a context to use a uds-client-server-link
 
void ConfigSetIsServer (bool data)
  C#: ctx.ConfigSetIsServer(bool data) C-API
set the MqSetupS.isServer value
 
void ConfigSetIsString (bool data)
  C#: ctx.ConfigSetIsString(bool data) C-API
set the MqConfigS.native value 'S'string or 'L'owEndian or 'B'igEndian
 
void ConfigSetName (string data)
  C#: ctx.ConfigSetName(string data) C-API
set the MqConfigS.dispName value and cleanup old value
 
void ConfigSetPkgsize (int data)
  C#: ctx.ConfigSetPkgsize(int data) C-API
set the MqIoConfigS.pkgsize value
 
void ConfigSetPostfix (string data)
  C#: ctx.ConfigSetPostfix(string data) C-API
set the client-part (2) of the application-identifer MqConfigS.dispName
 
void ConfigSetPrefix (string data)
  C#: ctx.ConfigSetPrefix(string data) C-API
set the server-part (1) of the application-identifer MqConfigS.dispName
 
void ConfigSetStartAs (MqStartE data)
  C#: ctx.ConfigSetStartAs(MqStartE data) C-API
set the MqConfigS.startAs value
 
void ConfigSetStartAsString (string data)
  C#: ctx.ConfigSetStartAsString(string data) C-API
set the MqConfigS.startAs value using string default, thread, fork or spawn
 
void ConfigSetStorage (string data)
  C#: ctx.ConfigSetStorage(string data) C-API
set the Storage value and cleanup old value
 
void ConfigSetTimeout (long data)
  C#: ctx.ConfigSetTimeout(long data) C-API
set the MqIoConfigS.timeout value
 
void EnvProtect ()
  C#: ctx.EnvProtect() C-API
protect the service-environment
 
void EnvRestore ()
  C#: ctx.EnvRestore() C-API
restore the service-environment
 
MkErrorC ErrorFORMAT ()
  C#: MkErrorC fmtobj.ErrorFORMAT() C-API
helper used to access MkErrorDEFAULT from MqContextC
 
MkErrorE ErrorCopy (MqContextC sourceCtx)
  C#: MkErrorE targetCtx.ErrorCopy(MqContextC sourceCtx) C-API
copy a MkErrorS from the sourceCtx to the targetCtx
 
MkErrorE ErrorMove (MqContextC sourceCtx)
  C#: MkErrorE targetCtx.ErrorMove(MqContextC sourceCtx) C-API
move a MkErrorS from the sourceCtx to the targetCtx
 
MqContextC LinkGetParent ()
  C#: MqContextC ctx.LinkGetParent() C-API
get the initial parent-context from a client/server link …
 
void LinkConnect ()
  C#: ctx.LinkConnect() C-API
re-connect a client-server-link after a server crash or a network downtime …
 
void LinkCreate (MkBufferListC args=null)
  C#: ctx.LinkCreate(MkBufferListC args = null) C-API
make ctx to a parent-context and setup a new client-server-link
 
void LinkCreateChild (MqContextC parent, MkBufferListC args=null)
  C#: ctx.LinkCreateChild(MqContextC parent, MkBufferListC args = null) C-API
make a context to a child-context on-top of an existing parent-client-server-link
 
void LinkCreateChild (MqContextC parent, params string[] args)
  C#: ctx.LinkCreateChild(MqContextC parent, MkBufferListC args = null) C-API
make a context to a child-context on-top of an existing parent-client-server-link
 
void LinkCreate (params string[] args)
  C#: ctx.LinkCreate(MkBufferListC args = null) C-API
make ctx to a parent-context and setup a new client-server-link
 
void LinkDelete ()
  C#: ctx.LinkDelete() C-API
close the client-server-link
 
int LinkGetCtxId ()
  C#: int ctx.LinkGetCtxId() C-API
get an identifier which is unique per parent-or-child-context
 
string LinkGetTargetIdent ()
  C#: string ctx.LinkGetTargetIdent() C-API
get the ident of the link-target
 
bool LinkIsConnected ()
  C#: bool ctx.LinkIsConnected() C-API
is the context connected? …
 
bool LinkIsParent ()
  C#: bool ctx.LinkIsParent() C-API
is the context a parent-context? …
 
void LinkShutdown ()
  C#: ctx.LinkShutdown() C-API
shutdown the communication with a server
 
void LogConfig (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0)
  C#: ctx.LogConfig(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0) C-API
log the MqContextC part MqConfigS
 
void LogEnv (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0)
  C#: ctx.LogEnv(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0) C-API
log the MqContextC part MqEnvS
 
void LogLink (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0)
  C#: ctx.LogLink(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0) C-API
log the MqContextC part MqLinkS
 
void LogSetup (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0)
  C#: ctx.LogSetup(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0) C-API
log the MqContextC part MqSetupS
 
void LogShort (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0, string label=null)
  C#: ctx.LogShort(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0, string label = null) C-API
log the MqContextC with less info then MqContextLog
 
new void LogType (MkObjectC fmtobj=null, int debug=0, [CallerMemberName]string callfunc=null, int lvl=0)
  C#: ctx.LogType(MkObjectC fmtobj = null, int debug = 0, [CallerMemberName]string callfunc = null, int lvl = 0) C-API
log the MqContextC part MkTypeS
 
string LogParentOrChild ()
  C#: string ctx.LogParentOrChild() C-API
is ctx a PARENT or a CHILD ? …
 
string LogServerOrClient ()
  C#: string ctx.LogServerOrClient() C-API
is ctx a SERVER or a CLIENT ? …
 
MkBufferC GetBuffer ()
  C#: MkBufferC ctx.GetBuffer() C-API
get the MqContextS.ctxbuf object
 
MqContextC GetRoot ()
  C#: MqContextC ctx.GetRoot() C-API
get the Root (toplevel initial context)
 
int Exit ([CallerMemberName]string callfunc=null, [CallerFilePath]string callfile=null, [CallerLineNumber]int callline=-1)
  C#: int ctx.Exit([CallerMemberName]string callfunc = null, [CallerFilePath]string callfile = null, [CallerLineNumber]int callline = -1) C-API
delete the context and exit the current process or thread …
 
void ProcessEvent (MqWaitOnEventE wait=MqWaitOnEventE.NO, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.ProcessEvent(MqWaitOnEventE wait = MqWaitOnEventE.NO, long timeout = (long)MkTimeoutE.DEFAULT) C-API
enter the event-loop and wait for an incoming service-request. …
 
void ProxyForward (MqContextC targetCtx, MqDumpC dump=null, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: sourceCtx.ProxyForward(MqContextC targetCtx, MqDumpC dump = null, long timeout = (long)MkTimeoutE.DEFAULT) C-API
send the entire read-data-package-data to the link-target
 
void ProxyItem (MqContextC targetCtx)
  C#: sourceCtx.ProxyItem(MqContextC targetCtx) C-API
Copy a single-data-item from the sourceCtx to the targetCtx.
 
MkBufferListC ReadALL (MkBufferListC val_inout=null)
  C#: MkBufferListC ctx.ReadALL(MkBufferListC val_inout = null) C-API
get a temporary MkBufferListC from all data in the read-data-package
 
MkBufferListC ReadBFL ()
  C#: MkBufferListC ctx.ReadBFL() C-API
get a temporary MkBufferListC from next list-item in the read-data-package
 
MkBufferC ReadBUF ()
  C#: MkBufferC ctx.ReadBUF() C-API
get a temporary MkBufferC from the read-data-package
 
byte[] ReadBIN ()
  C#: doc_mq_cs_ReadBIN C-API
generic function to read an MK_BIN object from the read-data-package object …
 
bool ReadBOL ()
  C#: doc_mq_cs_ReadBOL C-API
read a PRIMITIVE TYPE from the read-data-package
 
byte[] ReadBinaryR ()
  C#: byte[] ctx.ReadBinaryR() C-API
read a MkBinaryR from the read-data-package
 
double ReadDBL ()
  C#: doc_mq_cs_ReadDBL C-API
read a PRIMITIVE TYPE from the read-data-package
 
float ReadFLT ()
  C#: doc_mq_cs_ReadFLT C-API
read a PRIMITIVE TYPE from the read-data-package
 
Int32 ReadHDL ()
  C#: Int32 ctx.ReadHDL() C-API
read the handle from the read-data-package
 
short ReadI16 ()
  C#: doc_mq_cs_ReadI16 C-API
read a PRIMITIVE TYPE from the read-data-package
 
int ReadI32 ()
  C#: doc_mq_cs_ReadI32 C-API
read a PRIMITIVE TYPE from the read-data-package
 
long ReadI64 ()
  C#: doc_mq_cs_ReadI64 C-API
read a PRIMITIVE TYPE from the read-data-package
 
byte ReadI8 ()
  C#: doc_mq_cs_ReadI8 C-API
read a PRIMITIVE TYPE from the read-data-package
 
long ReadLONG ()
  C#: long ctx.ReadLONG() C-API
read the long native object from the read-data-package
 
string ReadSTR ()
  C#: doc_mq_cs_ReadSTR C-API
read a PRIMITIVE TYPE from the read-data-package
 
string ReadStringR ()
  C#: string ctx.ReadStringR() C-API
read a MkStringR from the read-data-package
 
void ReadL_END ()
  C#: ctx.ReadL_END() C-API
finish to extract a list-items from the read-data-package. …
 
void ReadL_START (MkBufferC buf=null)
  C#: ctx.ReadL_START(MkBufferC buf = null) C-API
start to extract a list-items from the read-data-package. …
 
void ReadT_END ()
  C#: ctx.ReadT_END() C-API
finish to extract a longterm-transaction-item 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-package. …
 
void ReadDbg ()
 ReadDbg
 
MkTypeE ReadGetNextType ()
  C#: MkTypeE ctx.ReadGetNextType() C-API
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
 
int ReadGetNumItems ()
  C#: int ctx.ReadGetNumItems() C-API
get the number of items left in the read-data-package
 
bool ReadItemExists ()
  C#: 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 …
 
MkBufferListC RouteGetTree ()
  C#: MkBufferListC ctx.RouteGetTree() C-API
create an overview about all available routing-target and services …
 
void RouteCreate (string route, string service, bool overwrite=false)
  C#: ctx.RouteCreate(string route, string service, bool overwrite = false) C-API
create/delete a routing-link between context an a service using route
 
void RouteDelete (string route, string service, bool overwrite=false)
  C#: ctx.RouteDelete(string route, string service, bool overwrite = false) C-API
delete a routing-link created with MqRouteCreate
 
MqContextC[] RouteResolve (string ident, int retnum=-1)
  C#: MqContextC[] ctx.RouteResolve(string ident, int retnum = -1) C-API
return a list of all context belonging to ident
 
void RouteTraverse (string service, MkBufferListC args=null)
  C#: ctx.RouteTraverse(string service, MkBufferListC args = null) C-API
traverse a tree down and call service if available.
 
void RouteTraverse (string service, params string[] args)
  C#: ctx.RouteTraverse(string service, MkBufferListC args = null) C-API
traverse a tree down and call service if available.
 
string RouteGetPath ()
  C#: string ctx.RouteGetPath() C-API
return the absolut route-connection-string up to the current ctx
 
void SendBFL (MkBufferListC val)
  C#: ctx.SendBFL(MkBufferListC val) C-API
append a MkBufferListC object to the send-data-package object …
 
void SendBIN (byte[] val)
  C#: doc_mq_cs_SendBIN C-API
append a MK_BIN object to the send-data-package. …
 
void SendBOL (bool val)
  C#: doc_mq_cs_SendBOL C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendBUF (MkBufferC val)
  C#: ctx.SendBUF(MkBufferC val) C-API
append a MkBufferC object to the send-data-package object …
 
void SendBUS_FLAT (MkBufferStreamC val)
  C#: ctx.SendBUS_FLAT(MkBufferStreamC val) C-API
append a MkBufferStreamC object to the send-data-package object …
 
void SendBinaryR (byte[] val)
  C#: ctx.SendBinaryR(byte[] val) C-API
append a MkBinaryR object to the send-data-package. …
 
void SendDBL (double val)
  C#: doc_mq_cs_SendDBL C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendFLT (float val)
  C#: doc_mq_cs_SendFLT C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendHDL (Int32 val)
  C#: ctx.SendHDL(Int32 val) C-API
send the handle to the send-data-package
 
void SendI16 (short val)
  C#: doc_mq_cs_SendI16 C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendI32 (int val)
  C#: doc_mq_cs_SendI32 C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendI64 (long val)
  C#: doc_mq_cs_SendI64 C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendI8 (byte val)
  C#: doc_mq_cs_SendI8 C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendLONG (long val)
  C#: ctx.SendLONG(long val) C-API
send the long native object to the send-data-package
 
void SendLTR (int transLId)
 SendLTR
 
void SendL_FLAT (MkBufferListC val)
  C#: ctx.SendL_FLAT(MkBufferListC val) C-API
append a MkBufferListC object as flat list of items to the send-data-package object …
 
void SendSTR (string val)
  C#: doc_mq_cs_SendSTR C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendStringR (string val)
  C#: ctx.SendStringR(string val) C-API
MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
 
void SendEND (string token, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND(string token, long timeout = (long)MkTimeoutE.DEFAULT) C-API
MqContextC - finish the send-data-block and call synchronous/asynchronous a remote-service
 
void SendEND_AND_CALLBACK (string token, MqServiceCCB callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_CALLBACK(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback
 
void SendEND_AND_CALLBACK (string token, MqServiceICB callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_CALLBACK(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback
 
void SendEND_AND_CALLBACK (string token, MqServiceIF callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_CALLBACK(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do not-wait for the result but expect the result on a callback
 
void SendEND_AND_SUB (string token, MqServiceCCB callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_SUB(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback
 
void SendEND_AND_SUB (string token, MqServiceICB callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_SUB(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback
 
void SendEND_AND_SUB (string token, MqServiceIF callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_SUB(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service, do wait for the result and expect multiple sub-results on a callback
 
void SendEND_AND_TRANSACTION (string token, string callback, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_TRANSACTION(string token, string callback, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service to do a longterm-transaction-call
 
void SendEND_AND_WAIT (string token, long timeout=(long) MkTimeoutE.DEFAULT)
  C#: ctx.SendEND_AND_WAIT(string token, long timeout = (long)MkTimeoutE.DEFAULT) C-API
finish the send-data-block, call the remote service and wait for result…
 
void SendSTART ()
  C#: ctx.SendSTART() C-API
initialize the send-data-package. …
 
void SendSYNC ()
  C#: ctx.SendSYNC() C-API
garantee that all pending asynchronous-service-calls are processed. …
 
void SendL_END ()
  C#: ctx.SendL_END() C-API
finish to append an embedded body-list-item to the send-data-package. …
 
void SendL_START ()
  C#: ctx.SendL_START() C-API
start to append an embedded body-list-item to the send-data-package. …
 
void SendT_END ()
  C#: ctx.SendT_END() C-API
closed a longterm-transaction-item
 
void SendT_START ()
  C#: ctx.SendT_START() C-API
open a longterm-transaction-item
 
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 optional return the results. …
 
void SendRETURN_SUB ()
  C#: ctx.SendRETURN_SUB() C-API
return Sub-Data-Blocks required by MqSendEND_AND_SUB
 
void ServiceCreate (string token, MqServiceCCB callback)
  C#: ctx.ServiceCreate(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback) C-API
create a link between a service-token and a service-callback
 
void ServiceCreate (string token, MqServiceICB callback)
  C#: ctx.ServiceCreate(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback) C-API
create a link between a service-token and a service-callback
 
void ServiceCreate (string token, MqServiceIF callback)
  C#: ctx.ServiceCreate(string token, MqServiceICB|MqServiceCCB|MqServiceIF callback) C-API
create a link between a service-token and a service-callback
 
void ServiceDelete (string token)
  C#: ctx.ServiceDelete(string token) C-API
delete a service. …
 
bool ServiceIsTransaction ()
  C#: bool ctx.ServiceIsTransaction() C-API
check if the ongoing-service-call belongs to a transaction …
 
void ServiceProxy (string token, int id=(int) MqSlaveE.OTHER)
  C#: ctx.ServiceProxy(string token, int id = (int)MqSlaveE.OTHER) C-API
create a service to link a master-context with a slave-context. …
 
void ServiceProxyCtx (string token, MqContextC target)
  C#: ctx.ServiceProxyCtx(string token, MqContextC target) C-API
same as MqServiceProxy but use an MqContextC as input.
 
bool ServiceProxyCtxExists (string token, MqContextC target)
  C#: bool ctx.ServiceProxyCtxExists(string token, MqContextC target) C-API
check if service who belongs to token is a proxy-service
 
void ServiceProxyRoundRobin (string token, string ident)
  C#: ctx.ServiceProxyRoundRobin(string token, string ident) C-API
create a proxy-service using Round-Robin as load-balancer …
 
void ServiceStorage (string token)
  C#: ctx.ServiceStorage(string token) C-API
setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE
 
bool ServiceTokenCheck (string token)
  C#: bool ctx.ServiceTokenCheck(string token) C-API
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token
 
bool ServiceTokenExists (string token)
  C#: bool ctx.ServiceTokenExists(string token) C-API
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
 
string ServiceTokenGet ()
  C#: string ctx.ServiceTokenGet() C-API
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer
 
MqContextC SlaveGetMaster ()
  C#: MqContextC ctx.SlaveGetMaster() C-API
opposite function of MqSlaveGetFilter
 
MqContextC SlaveGet (int id)
  C#: MqContextC ctx.SlaveGet(int id) C-API
get the slave-context from a master-context
 
MqContextC SlaveGetFilter ()
  C#: MqContextC ctx.SlaveGetFilter() C-API
get the filter-ctx or the master-ctx
 
MqContextC SlaveGetProxy (int id)
  C#: MqContextC ctx.SlaveGetProxy(int id) C-API
on slave return the master and on master return the slave identified by id.
 
bool SlaveCheck (int id)
  C#: bool ctx.SlaveCheck(int id) C-API
check if slave-id is valid
 
void SlaveCreate (int id, MqContextC slave)
  C#: ctx.SlaveCreate(int id, MqContextC slave) C-API
create a master/slave link between the master-parent-context and the slave-parent-context …
 
void SlaveDelete (int id)
  C#: ctx.SlaveDelete(int id) C-API
Delete a slave object from a master/slave link identified by id. …
 
bool SlaveIs ()
  C#: bool ctx.SlaveIs() C-API
is the context a slave-context ? …
 
void SlaveWorker (int id, string fct="WORKER", MkBufferListC args=null)
  C#: ctx.SlaveWorker(int id, string fct = "WORKER", MkBufferListC args = null) C-API
create a master/slave link using the image of the ctx object self. …
 
void SlaveWorker (int id, string fct="WORKER", params string[] args)
  C#: ctx.SlaveWorker(int id, string fct = "WORKER", MkBufferListC args = null) C-API
create a master/slave link using the image of the ctx object self. …
 
int StorageDelete (int transLIdP_inout=0)
  C#: int ctx.StorageDelete(int transLIdP_inout = 0) C-API
delete the storage-row identified by the transLIdP_inout
 
int StorageImport (int transLIdP_inout=0)
  C#: int ctx.StorageImport(int transLIdP_inout = 0) C-API
import the storage-package into the read-data-package
 
void StorageClose ()
  C#: ctx.StorageClose() C-API
close the storage. …
 
void StorageDecrRef (int transLId)
  C#: ctx.StorageDecrRef(int transLId) C-API
decrease the internal refCount lock of the database-entry
 
void StorageIncrRef (int transLId)
  C#: ctx.StorageIncrRef(int transLId) C-API
increase the internal refCount lock of the database-entry
 
void StorageLog ([CallerMemberName]string callfunc=null)
  C#: ctx.StorageLog([CallerMemberName]string callfunc = null) C-API
log the storage the status of the open transactions
 
void StorageOpen (string storageFile)
  C#: ctx.StorageOpen(string storageFile) C-API
switch to a file-based-transaction-database
 
int StorageCount ()
  C#: int ctx.StorageCount() C-API
count the number of storage-rows
 
int StorageErrCnt (int transLId)
  C#: int ctx.StorageErrCnt(int transLId) C-API
increment and return the database row-error-count for the row defined with transLId
 
int StorageExport ()
  C#: int ctx.StorageExport() C-API
export the read-data-package into the STORAGE
 
List< object > StorageResolve ()
  C#: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve() C-API
extract the context->link.protect.rmtTransLId entry from the database
 
 MqContextC (MqContextC tmpl=null)
 CONSTRUCTOR.
 
object ReadNEXT ()
  C#: object ctx.ReadNEXT() C-API
get the next argument as native object …
 
List< object > ReadLIST ()
  C#: List<object> ctx.ReadLIST() C-API
get all arguments as native list …
 
void ConfigSetIoTcp (List< object > items)
 
void ConfigSetIoTcp (params object[] items)
 
void ConfigSetIoTcp (params string[] items)
 
- Public Member Functions inherited from csmkkernel::MkObjectC
delegate void MkObjectDeleteSCB (string typeName, int typeHdl, int objHdl)
 
void ErrorCheck (MkErrorE err)
 
bool Check ()
 
string ToNameOfClass ()
 
void HandleDelete ()
 
bool HandleExists ()
 
Int32 HandleGet ()
 
Int32 HandleGetOfType ()
 
Int32 HandleGetOr0 ()
 
MkObjectC Next ()
 
MkObjectC Prev ()
 
void DbgDump (string message="var",[CallerMemberName]string callfunc=null)
 
void DbgL (string message, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
void DbgLogC ([CallerMemberName]string callfunc=null)
 
void DbgO ([CallerMemberName]string callfunc=null)
 
void DbgSTACK (int skip=0, int num=-1,[CallerMemberName]string callfunc=null)
 
void LogC (string message, int debug=0,[CallerMemberName]string callfunc=null)
 
void LogHEX (string callfunc, byte[] data)
 
void Log (MkObjectC fmtobj=null, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
void LogLong (MkObjectC fmtobj=null, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
void LogShort (MkObjectC fmtobj=null, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
void LogType (MkObjectC fmtobj=null, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
MkErrorC ErrorCatch (Exception exception=null,[CallerMemberName]string callfunc=null)
 
MkErrorC ToError ()
 
bool IsNull ()
 
string ToName ()
 
string ToNameOfType ()
 
override string ToString ()
 
int RefGet ()
 
void SysKill (int pid, int signal)
 
int SysGetPid ()
 
void Dispose ()
 
void Delete ()
 

Static Public Member Functions

static MqContextC MqContextC_ObjNew (IntPtr hdl)
 
static MqContextC MqContextC_ObjNewOrNull (IntPtr hdl)
 
new static MqContextC HandleResolve (Int32 netHdl)
  C#: [static] MqContextC MqContextC.HandleResolve(Int32 netHdl) C-API
Handle-Resolve-Slot - return a MqContextC from netHdl or null if invalid…
 
new static MqContextC Instances ()
  C#: [static] MqContextC MqContextC.Instances() C-API
get head-instance from linked-list of MqContextS type …
 
new static MqContextC GetNull ()
  C#: [static] MqContextC MqContextC.GetNull() C-API
Null-Slot - return a MqContextC typed NULL instance …
 
static MqContextC Create (MqContextC tmpl=null)
  C#: [constructor,static] MqContextC MqContextC.Create(MqContextC tmpl = null) C-API
create and initialize the MqContextC ...
 
- Static Public Member Functions inherited from csmkkernel::MkObjectC
static MkObjectC MkObjectC_ObjNew (IntPtr hdl)
 
static IntPtr getOBJ (string cls, MkObjectC obj)
 
static IntPtr getOBJ_null_allow (MkObjectC obj)
 
static MkObjectC HandleResolve (Int32 netHdl)
 
static void HandleDeleteByNetHdl (Int32 netHdl)
 
static MkObjectC Instances ()
 
static MkObjectC GetNull ()
 
static void DbgM (string message, int debug=0,[CallerMemberName]string callfunc=null, int lvl=0)
 
static int SysHashI32 (string key, int length=-1)
 
static string SysHashSTR (string key, int length=-1)
 
static void DeleteCallbackCleanup (string ident)
 
static void DeleteCallbackSetup (string ident, MkObjectDeleteSCB callback=null, string filter=null)
 
static int getPId ()
 
static int getTId ()
 
static string getStackTrace (int level=2)
 
static string getCallerProc (int level=2)
 
static int getCallerLine (int level=2)
 
static string getCallerFile (int level=2)
 

Static Protected Member Functions

static IntPtr CTOR (MqContextC tmpl=null)
  C#: [constructor,static] MqContextC MqContextC.Create(MqContextC tmpl = null) C-API
create and initialize the MqContextC ...
 
- Static Protected Member Functions inherited from csmkkernel::MkObjectC
static object atomObjNew (Type type, ConstructorInfo ctor, IntPtr obj)
 
static object atomObjCreate (Type type, ConstructorInfo ctor, IntPtr obj)
 
static IntPtr atomSelfCreate (ConstructorInfo ctor, IntPtr obj, IntPtr env)
 
static object atomSelfNull (ConstructorInfo ctor)
 
static void atomSelfUnlink (IntPtr self, IntPtr env)
 
static ConstructorInfo getCtor (Type type)
 
static string Name (IntPtr mkrt, IntPtr obj)
 
Object Send (string callSig, MqServiceICB data, params object[] objv)
 
Object Send (string callSig, MqServiceCCB data, params object[] objv)
 
Object Send (string callSig, MqServiceIF data, params object[] objv)
 
Object Send (string callSig, params object[] objv)
 

Additional Inherited Members

- Protected Member Functions inherited from csmkkernel::MkObjectC
 MkObjectC (IntPtr obj)
 
 MkObjectC ()
 
virtual void Dispose (bool disposing)
 
- Protected Attributes inherited from csmkkernel::MkObjectC
IntPtr pmkrt
 
- Properties inherited from csmkkernel::MkObjectC
IntPtr hdl
 
IntPtr hdl_null_allow
 
IntPtr mkrt
 

Detailed Description

MqContextC - the class known as ctx or context is the application-handle of the application-server and also the main data-handle

The context is the package-item with the required features and created by the implementation-layer-programmer. The context can be a client or a server.

HOWTO client-context

The client-context-creation is triggerd by the software-workflow on demand. The client is calling the MqLinkCreate to create a connection to the server using the connection-arguments to specify the target.

The life-cycle of a client is:

ContextCreate create and initialize the MqContextC ...
LinkCreate make ctx to a parent-context and setup a new client-server-link
SendTT MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
ReadTT read a PRIMITIVE TYPE from the read-data-package
LinkDelete close the client-server-link
ContextDelete Destructor - delete a MqContextC instance …
Exit delete the context and exit the current process or thread …

HOWTO server-context

The server-context-creation is always triggerd by the MqLinkCreate command of the client. The server is usually using a factory-constructor to call the MqContextCreate and finally to call the MqContextDelete.
The server-context is fully under control of the client.

The life-cycle of a server is:

SETUPdefine a class and add the setup/cleanup code
MqServerSetupIF define the server-setup-interface (callback) used on startup …
ServiceCreate create a link between a service-token and a service-callback
MqServerCleanupIF define the server-cleanup-interface (callback) used on cleanup …
ServiceDelete delete a service. …
STARTUPdefine the factory and start the listener
FactoryAdd Add a new MqFactoryC identified by factory-identifier and defined by factory-constructor
FactoryNew create a new MqContextC from a MqFactoryC
LinkCreate make ctx to a parent-context and setup a new client-server-link
ProcessEvent enter the event-loop and wait for an incoming service-request. …
WORKprocess the service-calls and exit on end
ReadTT read a PRIMITIVE TYPE from the read-data-package
SendTT MqContextC - append a native PRIMITIVE TYPE value to the send-data-package
Exit delete the context and exit the current process or thread …

MqContextC CTOR and DTOR

command alias
[constructor,static] MqContextC MqContextC.Create(MqContextC tmpl = null) csmqmsgque.MqContextC(?tmpl:MqContextC=nil?)
[destructor] ctx.Delete() ctx = None

Definition at line 21 of file MqHigh.cs.

Member Function Documentation

◆ MqContextC_ObjNew()

static MqContextC csmqmsgque.MqContextC.MqContextC_ObjNew ( IntPtr hdl)
inlinestatic

Definition at line 42 of file MqContextC.cs.

42 {
43 return hdl != IntPtr.Zero ? (MqContextC) atomObjNew(typeof(MqContextC), ctor, hdl) : MK_NULL.Value;
44 }
static object atomObjNew(Type type, ConstructorInfo ctor, IntPtr obj)
+ Here is the caller graph for this function:

◆ MqContextC_ObjNewOrNull()

static MqContextC csmqmsgque.MqContextC.MqContextC_ObjNewOrNull ( IntPtr hdl)
inlinestatic

Definition at line 78 of file MqContextC.cs.

78 {
79 return hdl != IntPtr.Zero ? (MqContextC) atomObjNew(typeof(MqContextC), ctor, hdl) : null;
80 }
+ Here is the caller graph for this function:

◆ MqServiceCCB()

delegate void csmqmsgque.MqContextC.MqServiceCCB ( MqContextC ctx)

implements the csmqmsgque API object: public version from MqTokenF as static

◆ MqServiceICB()

delegate void csmqmsgque.MqContextC.MqServiceICB ( )

implements the csmqmsgque API object: public version from MqTokenF as method

◆ Send() [1/4]

Object csmqmsgque.MqContextC.Send ( string callSig,
MqServiceCCB data,
params object[] objv )
inline

Definition at line 369 of file MqHigh.cs.

369 {
370 IntPtr data_ptr = (IntPtr)GCHandle.Alloc(new MqCall(mkrt,data));
371 return SendHigh(callSig, data_ptr, objv, 3);
372 }

◆ Send() [2/4]

Object csmqmsgque.MqContextC.Send ( string callSig,
MqServiceICB data,
params object[] objv )
inline

Definition at line 364 of file MqHigh.cs.

364 {
365 IntPtr data_ptr = (IntPtr)GCHandle.Alloc(new MqCall(mkrt,data));
366 return SendHigh(callSig, data_ptr, objv, 3);
367 }

◆ Send() [3/4]

Object csmqmsgque.MqContextC.Send ( string callSig,
MqServiceIF data,
params object[] objv )
inline

Definition at line 374 of file MqHigh.cs.

374 {
375 IntPtr data_ptr = (IntPtr)GCHandle.Alloc(new MqCall(mkrt,data));
376 return SendHigh(callSig, data_ptr, objv, 3);
377 }

◆ Send() [4/4]

Object csmqmsgque.MqContextC.Send ( string callSig,
params object[] objv )
inline

Definition at line 379 of file MqHigh.cs.

379 {
380 return SendHigh(callSig, IntPtr.Zero, objv, 2);
381 }

The documentation for this class was generated from the following files: