0

これはしばらくの間私を悩ませてきました。ストアド プロシージャの一部として、Oracle ストリームを使用して Oracle AQ キューにメッセージを書き込みます。以下は、関連するセクションを含むストアド プロシージャです。

CREATE OR REPLACE PROCEDURE ESBEVENT.esb_dml_handler(in_any IN ANYDATA) IS

l_enqueue_options dbms_aq.enqueue_options_t;
l_message_properties dbms_aq.message_properties_t;
l_message sys.aq$_jms_text_message;
l_msgid raw(16);
l_xmlmsg SYS.XMLTYPE;
err_num NUMBER;
err_msg VARCHAR2(100);

BEGIN
    BEGIN
    l_message := sys.aq$_jms_text_message.construct;
    l_xmlmsg := DBMS_STREAMS.CONVERT_LCR_TO_XML(in_any);
    l_message.set_text(l_xmlmsg.getClobVal());

    dbms_aq.enqueue
    ( queue_name => 'esbevent.esb_jms_queue'
    , enqueue_options => l_enqueue_options
    , message_properties => l_message_properties
    , payload => l_message
    , msgid => l_msgid
    );
    COMMIT;

    err_num := '';
    err_msg := 'Message Queued Successfully';

    EXCEPTION
    WHEN OTHERS THEN
        err_num := SQLCODE;
        err_msg := SUBSTR(SQLERRM, 1, 1000);
        INSERT INTO esbevent.esb_dml_handler_error_t VALUES (SYSDATE, err_num||' - '||err_msg );
END;

INSERT INTO esbevent.esb_jms_msg_memento_t VALUES (esb_jms_msg_memento_seq.nextval,     SYSDATE, l_xmlmsg, err_num||' - '||err_msg );
COMMIT;


END;

エンキューに続いて、XMLTYPE として送信されたメッセージをテーブル esb_jms_msg_memento_t に保存します。これは、後続の処理で問題が発生した場合に再送信できるようにするためです。現在、XMLTYPE フィールド データを抽出して AQ に再度書き込むブロックを作成しようとしています。これは現在、次のとおりです。

DECLARE
   l_enqueue_options      DBMS_AQ.ENQUEUE_OPTIONS_T;
   l_message_properties   DBMS_AQ.MESSAGE_PROPERTIES_T;
   l_message              SYS.aq$_jms_text_message;
   l_msgid                RAW (16);
   l_xmlmsg               XMLTYPE;

BEGIN
   SELECT msg_payload
     INTO l_xmlmsg
     FROM esb_jms_msg_memento_t
    WHERE UNIQUE_ID = '815929';

   l_message.set_text (l_xmlmsg.getClobVal ()); --null self error here


   DBMS_AQ.enqueue (queue_name           => 'esbevent.esb_jms_queue',
                    enqueue_options      => l_enqueue_options,
                    message_properties   => l_message_properties,
                    payload              => l_message,
                    msgid                => l_msgid);
   COMMIT;
END;

これを実行すると、次のエラーが表示されます。

ORA-30625: NULL SELF引数でのメソッド・ディスパッチは許可されていません ORA-06512: 22行目

XMLTYPE 変数を XMLTYPE フィールドに挿入できるようですが、その逆はできませんか???

4

1 に答える 1

0

投稿するとすぐに解決します...

l_message を作成するのを忘れました:

l_message := sys.aq$_jms_text_message.construct;

ああ！

于 2012-06-14T00:43:46.397 に答える