Writing MSMQ Server for MS Exchange Connector

#include <windows.h>
#include "mq.h"

int main(void)
{
    /*
     * Algorithm:
     *  1. Open the outgoing queue.
     *  2. Do an infinite loop:
     *   Read a message from outgoing queue.
     *   Pop-up a message box to the user.
     */

    /*
     * I assume this queue name. Replace this as necessary.
     * You need to create this queue manually before being able to send
     * messages to it via MSMQ Exchange Connector. Make sure its type
     * ID is {5EADC0D0-7182-11CF-A8FF-0020AFB8FB50}
     */
    #define MY_OUT_QUEUE_PATHNAME L"mig\\myoutbound"
 
    // Determine format name of the outgoing queue
    wchar_t wcsQueueFormatName[MAX_PATH];
    DWORD dwSize = MAX_PATH;
    HRESULT hRes = ::MQPathNameToFormatName(MY_OUT_QUEUE_PATHNAME,
           wcsQueueFormatName,
           &dwSize);
    if (FAILED(hRes))
        throw (-1);

    // Open the outgoing queue.
    QUEUEHANDLE hOutQueue = NULL;
    hRes = ::MQOpenQueue(wcsQueueFormatName,
         MQ_RECEIVE_ACCESS,
         MQ_DENY_RECEIVE_SHARE,
         &hOutQueue);
    if (FAILED(hRes))
        throw (-1);

    // Prepare our MQMSGPROPS struct
    MQMSGPROPS MsgProps;

    // We'll ask only for message bodies. Arrays of size 1 are enough.
    MQPROPVARIANT aVariant[1];
    MSGPROPID aPropId[1];

    #define MSG_BODY_LEN 2048 // For short messages this is enough
    unsigned char ucMsgBody[MSG_BODY_LEN];

    // Set the PROPID_M_BODY property.
    aPropId[0] = PROPID_M_BODY;    // PropId
    aVariant[0].vt = VT_VECTOR | VT_UI1; // Type
    aVariant[0].caub.cElems = MSG_BODY_LEN; // Buffer size.
    aVariant[0].caub.pElems = ucMsgBody; // Buffer

    // Set the MQMSGPROPS structure
    MsgProps.cProp = 1;    // Number of properties.
    MsgProps.aPropID = aPropId;  // Ids of properties.
    MsgProps.aPropVar = aVariant; // Values of properties.
    MsgProps.aStatus = NULL;  // No error report.
 
    // This is our infinite loop
    while (TRUE)
    {
        // Read one message from the queue
        hRes = ::MQReceiveMessage(hOutQueue,  // Handle to the queue
            1 * 60 * 1000,  // Timeout value in ms (1 min)
            MQ_ACTION_RECEIVE, // Action
            &MsgProps,   // Properties to retrieve
            NULL,    // Must be NULL for synchronous receive
            NULL,    // Must be NULL for synchronous receive
            NULL,    // No cursor
            MQ_NO_TRANSACTION); // No transaction
        if (SUCCEEDED(hRes))
            ::MessageBox(NULL, "Message retrieved from Exchange server!", "XConServer", MB_OK);
    }

    return 0;
}