Devart Forums

Code: Select all

private void OracleQueue_OnMessage(object sender,
    OracleQueueMessageEventArgs args)
{
    OracleQueue oracleQueue = (OracleQueue)sender;
    //We tweack the DequeueOptions of the oracle queue to only dequeue
    //the message of out interest
    OracleQueueMessageId originalMessageId =
        oracleQueue.DequeueOptions.MessageId;
    oracleQueue.DequeueOptions.MessageId = args.MessageId;
    OracleQueueMessage message = oracleQueue.Dequeue();
    oracleQueue.DequeueOptions.MessageId = originalMessageId;
    //proceed with message from here
}

Code: Select all

private void OracleQueue_OnMessage(object sender,
    OracleQueueMessageEventArgs args)
{
    OracleQueue oracleQueue = (OracleQueue)sender;
    //Dirty HACK because OracleQueueDequeueOptions does not implement ICloneable
    OracleQueueDequeueOptions dequeueOptions = (OracleQueueDequeueOptions)
        typeof(OracleQueueDequeueOptions).GetMethod("MemberwiseClone",
        BindingFlags.NonPublic | BindingFlags.Instance, null,
        Type.EmptyTypes, null).Invoke(oracleQueue, null);
    dequeueOptions.MessageId = args.MessageId;
    OracleQueueMessage message = oracleQueue.Dequeue(dequeueOptions);
    //proceed with message from here
}

Code: Select all

private void OracleQueue_OnMessage(object sender,
    OracleQueueMessageEventArgs args)
{
    OracleQueue oracleQueue = (OracleQueue)sender;
    //Ignore args.MessageId because it cannot be decently handeled
    //We just get any next message and dont care which message it has
    OracleQueueMessage message = oracleQueue.Dequeue();
    //proceed with message from here
}

Code: Select all

select * from COUNTRIES@HR