Снятие очереди с использованием Java для очереди Oracle 11g

Question

Я пытаюсь снять очередь с очереди Oracle 11g, используя автономную Java.Вот код:

public class testq {
public static void main(String[] args) throws Exception {   
    testq q = new testq();      

    AQSession aq_sess = createSession();
    q.runTest(aq_sess);
}

 public static AQSession createSession() {
      Connection db_conn;
      AQSession  aq_sess = null;

      try {               
         DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());

         /* Load the Oracle8i AQ driver: */
         Class.forName("oracle.AQ.AQOracleDriver");

         db_conn = DriverManager.getConnection("jdbc:oracle:thin:@10.10.10.10:1521:demo", "demo_app", "demo");

         System.out.println("JDBC Connection opened "); 
         db_conn.setAutoCommit(false);


         /* Creating an AQ Session: */
         aq_sess = AQDriverManager.createAQSession(db_conn);
         System.out.println("Successfully created AQSession ");  
      }
      catch (Exception ex) {
         System.out.println("Exception: " + ex); 
         ex.printStackTrace();      
      }  
      return aq_sess;
   }

  public void runTest(AQSession aq_sess)  {
       //AQQueueTable             q_table;
       AQQueue                  queue;
       AQMessage                message;
       AQRawPayload             raw_payload;
       AQDequeueOption          deq_option;
       byte[]                   b_array;
       Connection               db_conn;

     try {
       db_conn = ((AQOracleSession)aq_sess).getDBConnection();

   /* Get a handle to a queue - aq_queue4 in aquser schema: */
       queue = aq_sess.getQueue ("myadmin", "STREAM_QUEUE_DEMO");
       System.out.println("Successful getQueue");  

   /* Creating a AQDequeueOption object with default options: */
       deq_option = new AQDequeueOption();

       deq_option.setDequeueMode(AQDequeueOption.DEQUEUE_REMOVE);

       /* Set wait time to 10 seconds: */
       deq_option.setWaitTime(10);

   /* Dequeue a message: */
       message = queue.dequeue(deq_option);
       System.out.println("Successful dequeue"); 

   /* Retrieve raw data from the message: */
       raw_payload = message.getRawPayload();
       b_array = raw_payload.getBytes();
       db_conn.commit();

       String value = new String(b_array);
       System.out.println("queue="+value);  
     } catch(Exception e) {
         e.printStackTrace();
     }
  } 

Но я получаю сообщение об ошибке в строке ниже:

    message = queue.dequeue(deq_option);

Ошибка говорит

oracle.AQ.AQException: JMS-174: Class must be specified for queues with object payloads
Use dequeue(deq_option, payload_fact) or dequeue(deq_option, sql_data_cl)

Может ли кто-нибудь помочь мнеисправить эту ошибку?Мне нужно сразу убрать сообщение из очереди.

Спасибо!

Answer 1

Что именно вы ставите в очередь? т. е. какова ваша полезная нагрузка?
Когда вы создаете Oracle Streams AQ, вы должны указать тип полезной нагрузки, который будет поставлен в очередь в Q.
А для типов полезных данных объекта вы должны добавить информацию о классе в AQSession перед удалением из очереди. например мы снимаем с наследства объект Oracle XMLType, поэтому нам нужно добавить следующий фрагмент кода сразу после создания сеанса.

Map map = session.getTypeMap();
map.put("SYS.XMLTYPE", Class.forName("oracle.xdb.XMLTypeFactory"));

Вы должны будете сделать что-то подобное, основываясь на вашем типе полезной нагрузки.