用MSGID对ODP.NET进行Oracle AQ的去队列

Question

我正在尝试使用ODP.NET by服务将来自oracle的消息排出队列。

我有两个条件

队列表中要退出队列的记录的

1. MessageID将由服务
2. 提供，一旦服务去队列，记录不应该对其他服务实例可用的消息，意味着在事务提交或事务过期

之前，它应该被锁定

发行：

1. DequeueOptions MsgID没有识别我的MSGID
2. ，无法找到如何从排队列中锁定相同msg ID

中的其他实例

我的队伍就像

BEGIN DBMS_AQADM.CREATE_QUEUE_TABLE(
     Queue_table        => '"DEVENV1_CUSTOM"."INTEGRATION_MSG_QUEUE"',
     Queue_payload_type => '"DEVENV1_CUSTOM"."TRIGGER_AUDIT_TYPE"',
     Sort_list          => 'ENQ_TIME',
     Compatible         => '10.0.0',
     primary_instance   => 3,
     secondary_instance => 2);
  END;

有人能建议我一种将记录的msgid从队列中删除的方法吗?以及如何将它们从访问队列的其他人锁起来直到提交或超时。

public static void DequeueMessage(string MessageID)
        {
            // Create connection
            string constr = "my constring";
            Oracle.DataAccess.Client.OracleConnection con = new Oracle.DataAccess.Client.OracleConnection(constr);
            // Create queue
            OracleAQQueue queue = new OracleAQQueue("DEVENV1_CUSTOM.INTEGRATION_MSG_QUEUE_Q", con);
            try
            {
                // Open connection
                con.Open();     
                // Begin txn for enqueue
                Oracle.DataAccess.Client.OracleTransaction txn = con.BeginTransaction();
                // Prepare to Dequeue
                queue.DequeueOptions.Visibility = OracleAQVisibilityMode.OnCommit;

                queue.DequeueOptions.Wait = 10;

                queue.DequeueOptions.DequeueMode = OracleAQDequeueMode.Locked;

                // Set message type for the queue
                queue.MessageType = OracleAQMessageType.Udt;

                queue.UdtTypeName = "TRIGGER_AUDIT_TYPE";        

                queue.DequeueOptions.MessageId = System.Text.Encoding.ASCII.GetBytes ("A0CB9F328889420D8F0C8A62BF38B454");

                // Dequeue message
                OracleAQMessage deqMsg = queue.Dequeue();

                TRIGGER_AUDIT_TYPE data = (TRIGGER_AUDIT_TYPE)deqMsg.Payload;

                // Dequeue txn commit
                txn.Commit();

            }
            catch (Exception e)
            {
                Console.WriteLine("Error: {0}", e.Message);
               
            }
            finally
            {
                // Close/Dispose objects

                con.Close();
                con.Dispose();
            }

        }

Answer 1

问题是甲骨文返回的字节数组和.net创建的字节数组是不同的(如果被插入，请阅读关于小Endian和Big的信息)。

因此，我解决了这个问题，直接从oracle中转换数组，并将其用于Dequeue。

  OracleCommand oracleCommand = new OracleCommand("Select MSGID  from INTEGRATION_MSG_QUEUE where msgid='B85439241C9241A4A6B1869F08F382E7'", con);
            var K=  oracleCommand.ExecuteScalar();
            Byte[] rawBytesFromOracle =K as byte[];
           


            // Begin txn for enqueue
            Oracle.DataAccess.Client.OracleTransaction txn = con.BeginTransaction();
            // Prepare to Dequeue
            queue.DequeueOptions.Visibility = OracleAQVisibilityMode.OnCommit;

            queue.DequeueOptions.Wait = 10;

            queue.DequeueOptions.DequeueMode = OracleAQDequeueMode.Locked;

            queue.DequeueOptions.MessageId = rawBytesFromOracle;


            // Set message type for the queue
            queue.MessageType = OracleAQMessageType.Udt;

            queue.UdtTypeName = "TRIGGER_AUDIT_TYPE";


            Console.WriteLine("DeQueueing ............ ");

            // Dequeue message
            OracleAQMessage deqMsg = queue.Dequeue();

            TRIGGER_AUDIT_TYPE data = (TRIGGER_AUDIT_TYPE)deqMsg.Payload;

            Console.WriteLine("Dequeued message...." + data.CMESSAGEBODY );