Работа с MSMQ

[Dimonishe]

EVGL спасибо!

Нашел вот еще классец GatewayQueryMSMQReceive. Там вроде как раз чтение из очереди...

А постоянное чтение прийдется, как я понимаю, пакетником организовывать.

[EVGL]

Цитата:

Сообщение от Dimonishe

А постоянное чтение прийдется, как я понимаю, пакетником организовывать.

Да. Вот примерчик:

void ScanDirectory(FilePath _folderPath, GatewayOrgId _gatewayOrgId)
{
    int                             hndFile;
    boolean                         showInfo = true;
    FileName                        scanFileName;
    ProblemGatewayImportProtocol    importProtocol;
    ;

    if (! _folderPath)
        throw error("@SFI525");

    if (! _gatewayOrgId)
        throw error("@SFI529");

    if (! WinAPI::folderExists(_folderPath))
       throw error( strfmt("@SFI526", _folderPath) );

    gatewayOrgId = _gatewayOrgId;

    [hndFile, scanFileName] = WinAPI::findFirstFile(_folderPath + "\\*.tmp");

    while (scanFileName)
    {
        fileName = _folderPath + scanFileName;

        if (!ProblemGatewayImportProtocol::exist(fileName))
        {
            if (showInfo)
            {
                info("@SFI527");
                showInfo = false;
            }

            importProtocol.clear();
            importProtocol.FilePath = fileName;
            importProtocol.GatewayOrgId = gatewayOrgId;

            try
            {
                this.run();
                importProtocol.ImportStatus = ImportStatus::Imported;
            }
            catch
            {
                importProtocol.ImportStatus = ImportStatus::InvalidFile;
            }

            importProtocol.insert();
        }

        scanFileName = WinAPI::findNextFile(hndFile);
    }

}

В целом, надо заметить, что MSMQ работает много медленнее, чем файловая система NTFS.

[Dimonishe]

Цитата:

Сообщение от EVGL

В целом, надо заметить, что MSMQ работает много медленнее, чем файловая система NTFS.

Беда в том, что с другой стороны используется MSMQ и все равно прийдется им посылать инфу о том что Аксапта скушала данные, и положила результат назад ((

Вот пробую простенький примерчик

static void MSMQ_send(Args _args)
{
    #MSMQ

    MSMQQueueInfo               queueInfo;
    MSMQQueue                   queue;
    MSMQMessage                 message;

    MSMQTransactionDispenser    dispenser = new MSMQTransactionDispenser();
    MSMQTransaction             transaction;
    str res;
    queueInfo = new MSMQQueueInfo();

    queueInfo.pathName("psp\private$\axapta_queue"); //psp имя локальной машины

    queue = queueinfo.open(#MQ_SEND_ACCESS, #MQ_DENY_NONE); //тут все валится

    transaction = dispenser.BeginTransaction();

    message = new MSMQMEssage();
    message.Label("Label");
    message.BodyText("Message!!!");

    message.sendInTransaction(queue, transaction);

    transaction.Commit();

    //  Close the queue.
    queue.Close();

}

на методе open вываливается с ошибкой:

Метод 'Open' в COM-объекте класса 'MSMQ.MSMQQueueInfo' возвратил код ошибки 0xC00E0014 (<неизвестно>), который означает: Указаны недопустимые путь и/или имя очереди. .


чего ему не нравится... не пойму