Announcement

Collapse
No announcement yet.

OAQ inbound sample

Collapse
X
 
  • Filter
  • Time
  • Show
Clear All
new posts

  • OAQ inbound sample

    Dear all,

    Here's my code to use OTM default OAQ (table:intg_queue)
    Code:
            T2SharedConnection t2Conn = new T2SharedConnection("OAQ");
            t2Conn.open();
            String xml = TransmissionMan.readTransmissionFromFile("C:\\Users\\Vincent\\Desktop\\xml.txt");
            OaqUtil.enqueue(t2Conn, xml, "inbound_aq");
            t2Conn.close();
    You need to setup glog properties, add below:
    glog.oaq.integration.xml_stage_aq=1

    Then start 4 default OAQ listeners use below command in sqlplus
    execute pkg_queue_management.start_database_queue_listener ('inbound_aq','xml_stage_aq','ack_aq','exception_a q')

    You can "select * from intg_queue" to check the ACK_AQ.
    Vincent Van
    OTM Customization Service
    [email protected]
Working...
X