Difference between revisions of "MQCURMSGS()"
From Recital Documentation Wiki
Yvonnemilne (Talk | contribs) |
Yvonnemilne (Talk | contribs) |
||
| Line 1: | Line 1: | ||
| − | |||
==Purpose== | ==Purpose== | ||
Return the number of unread messages in the specified queue | Return the number of unread messages in the specified queue | ||
| Line 13: | Line 12: | ||
==Description== | ==Description== | ||
| − | The MQCURMSGS() function returns the current number of unread messages in the queue specified by <expN>. | + | The MQCURMSGS() function returns the current number of unread messages in the open queue specified by <expN>. The <expN> is the pointer to a queue opened with MQCREATE() or MQOPEN(). |
| + | |||
| + | The MQCLOSE() function is used to close a queue which has been opened with MQOPEN() or MQCREATE(). | ||
==Example== | ==Example== | ||
<code lang="recital"> | <code lang="recital"> | ||
| + | // Open up the queue for reading | ||
mqdes=mqopen("/myqueue") | mqdes=mqopen("/myqueue") | ||
if (mqdes < 0) | if (mqdes < 0) | ||
| − | + | messagebox(strerror()+",errno="+alltrim(str(error()))) | |
| − | + | return | |
endif | endif | ||
| + | // do while there are messages | ||
do while (mqcurmsgs(mqdes) > 0) | do while (mqcurmsgs(mqdes) > 0) | ||
| − | + | // Get each message | |
| − | + | mstr=mqreceive(mqdes) | |
| − | + | if (empty(mstr)) | |
| − | + | messagebox(strerror()+",errno="+alltrim(str(error()))) | |
| − | + | return | |
| − | + | endif | |
| − | + | messagebox(mstr) | |
| + | enddo | ||
mqclose(mqdes) | mqclose(mqdes) | ||
</code> | </code> | ||
Revision as of 11:14, 19 November 2009
Purpose
Return the number of unread messages in the specified queue
Syntax
MQCURMSGS(<expN>)
See Also
MQCLOSE(), MQCREATE(), MQOPEN(), MQRECEIVE(), MQSEND()
Description
The MQCURMSGS() function returns the current number of unread messages in the open queue specified by <expN>. The <expN> is the pointer to a queue opened with MQCREATE() or MQOPEN().
The MQCLOSE() function is used to close a queue which has been opened with MQOPEN() or MQCREATE().
Example
// Open up the queue for reading mqdes=mqopen("/myqueue") if (mqdes < 0) messagebox(strerror()+",errno="+alltrim(str(error()))) return endif // do while there are messages do while (mqcurmsgs(mqdes) > 0) // Get each message mstr=mqreceive(mqdes) if (empty(mstr)) messagebox(strerror()+",errno="+alltrim(str(error()))) return endif messagebox(mstr) enddo mqclose(mqdes)
Products
Recital, Recital Server
