使用Java为Oracle 11g队列出队

我想使用Oracle 11g队列使用独立Java进行出队。下面是代码：使用Java为Oracle 11g队列出队

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)

任何一个可以帮助我解决这个错误？我需要立即批量消除邮件。

谢谢！

来源

2011-12-22 Mike

你到底在干什么？即你的有效载荷是什么？
创建Oracle Streams AQ时，必须指定将在Q.中排队的有效内容类型。
对于对象有效内容类型，您必须在取消排队之前将类信息添加到AQSession中。例如我们将Oracles原生XMLType对象出队，因此我们必须在创建会话后添加以下代码片段。

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

您必须根据您的有效负载类型进行类似的操作。

来源

2011-12-22 19:21:44

嗨，你能帮忙吗？有效负载类型是sys.aq $ _jms_text_message – Mike 2011-12-22 20:56:53

您可以分享您的Q创建脚本以及入队代码吗？ – 2011-12-23 16:48:44

使用Java为Oracle 11g队列出队

回答

相关问题