Devart Forums

Code: Select all

void EnDeQueue() {
  string connString = "server=***;uid=***;pwd=***;";
  string queueName = "myQueue";
  int batchSize = 20;
  //EnQueue
  using (OracleConnection connection = new OracleConnection(connString)) {
    connection.Open();

    OracleCommand oracleCommand = new OracleCommand("CREATE OR REPLACE TYPE my_type AS OBJECT (id NUMBER(4), " + "mestext VARCHAR2(80));", connection);
    oracleCommand.ExecuteNonQuery();
    oracleCommand.CommandText = "CREATE OR REPLACE TYPE my_type_array is VARRAY(20) OF my_type;";
    oracleCommand.ExecuteNonQuery();

    OracleQueueTable oracleQueueTable = new OracleQueueTable("QUEUE_TABLE_MESSAGE", connection);
    oracleQueueTable.Options.PayloadTypeName = "my_type";
    oracleQueueTable.CreateQueueTable();
    OracleQueueAdmin oracleQueueAdmin = new OracleQueueAdmin(queueName, "QUEUE_TABLE_MESSAGE", connection);
    oracleQueueAdmin.CreateQueue();
    oracleQueueAdmin.StartQueue();
    OracleQueue oracleEnqueueQueue = new OracleQueue(queueName, connection);
    OracleObject obj = new OracleObject("my_type", connection);
    for (int i = 0; i < 10; i++) {
      obj["id"] = i;
      obj["mestext"] = "hello!";
      oracleEnqueueQueue.Enqueue(obj);
    }
    connection.Close();
  }

  //DeQueue
  using (OracleConnection connection = new OracleConnection(connString)) {
    connection.Open();
    using (OracleQueue oracleDequeueQueue = new OracleQueue(queueName, connection)) {

      //setting the array type name for object type queues
      oracleDequeueQueue.PayloadArrayTypeName = "my_type_array";

      oracleDequeueQueue.DequeueOptions.Navigation = OracleQueueNavigation.FirstMessage;
      oracleDequeueQueue.DequeueOptions.DeliveryMode = OracleQueueDeliveryMode.Persistent;
      oracleDequeueQueue.DequeueOptions.Visibility = OracleQueueVisibility.Immediate;
      oracleDequeueQueue.DequeueOptions.DequeueMode = OracleQueueDequeueMode.Remove;
      oracleDequeueQueue.DequeueOptions.WaitTimeout = 0;
      OracleQueueMessage[] qMsgs;
      try {
        qMsgs = oracleDequeueQueue.DequeueArray(batchSize);
      }
      catch (OracleException e) {
        if (e.Code == 25228) {
          Console.WriteLine("No messages to dequeue");
        }
        throw (e);
      }
    }
  }
}