Code: Select all
_conn = new OracleConnection();
_conn.UserId = "xxx";
_conn.Password = "yyy";
_conn.Server = "zzz";
_conn.Open();
_queue = new OracleQueue("REQUEST_QUEUE", _conn);
_queue.DequeueOptions.ConsumerName = "abc";
_queue.DequeueOptions.WaitTimeout = 0;
_queue.DequeueOptions.DequeueMode = OracleQueueDequeueMode.Locked;
_queue.AsyncNotification = true;
_queue.OnMessage += new OracleQueueMessageEventHandler(_queue_OnMessage);