Functions
native void	org.endurox.AtmiCtx.tpenqueue (String qspace, String qname, TPQCTL ctl, TypedBuffer idata, long flags)

native void	org.endurox.AtmiCtx.tpenqueueex (short nodeid, short srvid, String qname, TPQCTL ctl, TypedBuffer idata, long flags)

native TypedBuffer	org.endurox.AtmiCtx.tpdequeue (String qspace, String qname, TPQCTL ctl, TypedBuffer odata, long flags)

native TypedBuffer	org.endurox.AtmiCtx.tpdequeueex (short nodeid, short srvid, String qname, TPQCTL ctl, TypedBuffer odata, long flags)

Detailed Description

Queue handling

Function Documentation

native TypedBuffer org.endurox.AtmiCtx.tpdequeue	(	String	qspace,
		String	qname,
		TPQCTL	ctl,
		TypedBuffer	odata,
		long	flags
	)

Dequeue message from Queue sub-system See tpdequeue(3) manpage for more information.

Parameters

qspace	queue space name
qname	queue name
ctl	queue control obj
odata	output data to rewrite received message
flags	TPNOTRAN, TPSIGRSTRT, TPNOTIME, TPNOCHANGE, TPNOBLOCK

Returns: Returned buffer from queue. Not that ctl will contain metadata about the message

Exceptions

AtmiTPEINVALException	data is NULL, qspace is NULL, or nodeid and srvid is 0. Error can be generate in case if qname is empty or NULL. ctl is NULL or data does not point to tpalloc() allocated buffer.
AtmiTPENOENTException	Tmqueue server is not available.
AtmiTPETIMEException	Service did not reply in given time (NDRX_TOUT).
AtmiTPEDIAGNOSTICException	More information is provided in TPQCTL.diagnostic field.
AtmiTPESVCFAILException	Tmqueue Service returned TPFAIL. This is application level failure.
AtmiTPESVCERRException	Tmqueue service got system level failure. Server died during the message presence in service queue.
AtmiTPESYSTEMException	Enduro/X internal error occurred. See logs for more info.
AtmiTPEOSException	System failure occurred during serving. See logs i.e. user log, or debugs for more info.

native TypedBuffer org.endurox.AtmiCtx.tpdequeueex	(	short	nodeid,
		short	srvid,
		String	qname,
		TPQCTL	ctl,
		TypedBuffer	odata,
		long	flags
	)

Dequeue message from Queue sub-system See tpdequeueex(3) manpage for more information.

Parameters

nodeid	Cluster node ID on which queue server is present
srvid	Queue Server ID on given cluster node id
qname	queue name
ctl	queue control obj
odata	output data to rewrite received message
flags	TPNOTRAN, TPSIGRSTRT, TPNOTIME, TPNOCHANGE, TPNOBLOCK

Returns: Returned buffer from queue. Not that ctl will contain metadata about the message

Exceptions

AtmiTPEINVALException	data is NULL, qspace is NULL, or nodeid and srvid is 0. Error can be generate in case if qname is empty or NULL. ctl is NULL or data does not point to tpalloc() allocated buffer.
AtmiTPENOENTException	Tmqueue server is not available.
AtmiTPETIMEException	Service did not reply in given time (NDRX_TOUT).
AtmiTPEDIAGNOSTICException	More information is provided in TPQCTL.diagnostic field.
AtmiTPESVCFAILException	Tmqueue Service returned TPFAIL. This is application level failure.
AtmiTPESVCERRException	Tmqueue service got system level failure. Server died during the message presence in service queue.
AtmiTPESYSTEMException	Enduro/X internal error occurred. See logs for more info.
AtmiTPEOSException	System failure occurred during serving. See logs i.e. user log, or debugs for more info.

native void org.endurox.AtmiCtx.tpenqueue	(	String	qspace,
		String	qname,
		TPQCTL	ctl,
		TypedBuffer	idata,
		long	flags
	)

Enqueue message to persistent storage See tpenqueue(3) manpage for more information.

Parameters

qspace	queue space name
qname	queue name
ctl	queue control obj
idata	data buffer
flags	flags TPNOTRAN, TPSIGRSTRT, TPNOTIME, TPNOBLOCK, TPNOABORT

Exceptions

AtmiTPEINVALException	data is NULL, qspace is NULL, or nodeid and srvid is 0. Error can be generate in case if qname is empty or NULL. ctl is NULL or data does not point to tpalloc() allocated buffer.
AtmiTPENOENTException	Tmqueue server is not available.
AtmiTPETIMEException	Service did not reply in given time (NDRX_TOUT).
AtmiTPEDIAGNOSTICException	More information is provided in TPQCTL.diagnostic field. For this exception use getQctl() to get original TPQCTL passed to method call.
AtmiTPESVCFAILException	Tmqueue Service returned TPFAIL. This is application level failure.
AtmiTPESVCERRException	Tmqueue service got system level failure. Server died during the message presence in service queue.
AtmiTPESYSTEMException	Enduro/X internal error occurred. See logs for more info.
AtmiTPEOSException	System failure occurred during serving. See logs i.e. user log, or debugs for more info.

native void org.endurox.AtmiCtx.tpenqueueex	(	short	nodeid,
		short	srvid,
		String	qname,
		TPQCTL	ctl,
		TypedBuffer	idata,
		long	flags
	)

Enqueue message to persistent storage, extended See tpenqueueex(3) manpage for more information.

Parameters

nodeid	Cluster node ID on which queue server is present
srvid	Queue Server ID on given cluster node id
qname	queue name
ctl	queue control obj
idata	data buffer
flags	flags TPNOTRAN, TPSIGRSTRT, TPNOTIME, TPNOBLOCK, TPNOABORT

Exceptions

AtmiTPEINVALException	data is NULL, qspace is NULL, or nodeid and srvid is 0. Error can be generate in case if qname is empty or NULL. ctl is NULL or data does not point to tpalloc() allocated buffer.
AtmiTPENOENTException	Tmqueue server is not available.
AtmiTPETIMEException	Service did not reply in given time (NDRX_TOUT).
AtmiTPEDIAGNOSTICException	More information is provided in TPQCTL.diagnostic field. For this exception use getQctl() to get original TPQCTL passed to method call.
AtmiTPESVCFAILException	Tmqueue Service returned TPFAIL. This is application level failure.
AtmiTPESVCERRException	Tmqueue service got system level failure. Server died during the message presence in service queue.
AtmiTPESYSTEMException	Enduro/X internal error occurred. See logs for more info.
AtmiTPEOSException	System failure occurred during serving. See logs i.e. user log, or debugs for more info.