INtime SDK Help
INtime SDK v7.1 > About INtime > INtime Kernel > Message Queues > ntxReceiveRtDataMessage

Receives a data message from a queue object.

BOOLEAN ntxReceiveRtDataMessage(
LPVOID msgBuffer,
DWORD msgBufferSize,
DWORD msWait,
DWORD *pMsgSize);


A handle for a valid queue object.
A pointer to a contiguous buffer where the message is to be received.
Size on bytes of the message buffer.
The number of milliseconds for which the calling thread should wait for a message.
A pointer to a DWORD location where the number of bytes actually received is returned.

Additional information

If a short message is available on the queue the data is received into the buffer specified by the msgBuffer parameter. If the buffer specified is not large enough to receive the next available message the call fails with status E_LIMIT and the call may be retried with a larger buffer. The required buffer size will be returned through the pMsgSize parameter.

If a long message has been sent to the queue, the call will return FALSE with a special status of E_NO_LOCAL_BUFFER (returned through ntxGetLastRtError). The message buffer will contain a structure of type MSG_DESCRIPTOR which is used to identify the long message. The caller must then call GetRtLongDataMessage to retrieve the data.


Returns TRUE on success. Returns FALSE on failure. Call ntxGetLastRtError() to find the failure status. Possible status values include:
E_EXIST The hQueue parameter does not refer to an existing object
E_LIMIT The buffer specified is not large enough to receive the next message in the queue.
E_TYPE The hQueue parameter does not refer to a valid queue object.
E_NO_LOCAL_BUFFER A long message has been sent. The value pointed to by the msgSize parameter contains the number of bytes in the long message. The caller must now call GetRtLongDataMessage to receive the data.
E_TIME The call timed out before a message was received.
E_BAD_ADDR The msgBuffer parameter is not valid.
E_PARAM The msWAit parameter is not valid. It must be between 0 and 655359, or WAIT_FOREVER


Versions Defined in Include Link to
INtime 5.0 intime/nt/include/ntx.h ntx.h ntx.lib, ntxext.lib
See Also

Message Queues