Прошу помощи клуба, по следующему вопросу.
Стоит задача осуществить интеграцию между сервисом на ESB и Oracle, используется асинхронная схема;

Есть две очереди: запрсов и ответов;

Задача заключается в том, что запросы могут отправлятся от разных консьюмеров,
и при этом когда происходит чтение, консьюмер должен читать только свои сообщения,
то есть необходимо скоррелировать запрос сс ответом.

Пробовал писать на форуме Oracle, к сожалению, рекомендаций никаких не получил.

FUNCTION request
(
v_queue_name varchar2,
v_Message varchar2
)
RETURN boolean IS
enqueue_options dbms_aq.enqueue_options_t;
message_properties dbms_aq.message_properties_t;
msgid RAW(16);
payload sys.mgw_basic_msg_t;
header sys.mgw_name_value_array_t;
text_body sys.mgw_text_value_t;
text_body_raw sys.mgw_raw_value_t;
BEGIN

-- Устанавливаем необходимые параметры для MQ
header := sys.mgw_name_value_array_t(
sys.mgw_name_value_t.construct_integer('MGW_MQ_characterSet', '1208'),
sys.mgw_name_value_t.construct_integer('MGW_MQ_priority', '7'),
sys.mgw_name_value_t.CONSTRUCT_TEXT('MGW_MQ_replyToQueueName', 'REQEST_QU'));

-- Если 1 параметр, то сообщение < 2к, если 2 > 2к
text_body := sys.mgw_text_value_t(NULL,v_message);

-- Construct the message from its constituent parts.
payload := sys.mgw_basic_msg_t(header, text_body, NULL);

dbms_aq.enqueue(queue_name => v_queue_name,
enqueue_options => enqueue_options,
message_properties => message_properties,
payload => payload,
msgid => msgid);
RETURN TRUE;

EXCEPTION
WHEN OTHERS THEN
DBMS_OUTPUT.put_line(SQLERRM);
RETURN FALSE;
END;
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
FUNCTION request
(
v_Q_NAME IN varchar2
)
RETURN boolean
IS
dequeue_options dbms_aq.dequeue_options_t;
message_properties dbms_aq.message_properties_t;
msgid RAW(16);
payload SYS.MGW_BASIC_MSG_T;
header sys.mgw_name_value_array_t;

v_CLOB CLOB;
v_RC NUMBER;
v_BODY CLOB;
v_FILE UTL_FILE.file_type;

v_ERRMSG VARCHAR2(512);

BEGIN

DBMS_OUTPUT.enable;

-- FIRST_MESSAGE
dequeue_options.navigation := 1;
dequeue_options.wait := dbms_aq.NO_WAIT;



BEGIN
dbms_aq.dequeue(queue_name => v_Q_NAME,
dequeue_options => dequeue_options,
message_properties => message_properties,
payload => payload,
msgid => msgid);
EXCEPTION
WHEN OTHERS THEN
IF SQLCODE = -25228 THEN
RETURN FALSE;
ELSE
DBMS_OUTPUT.put_line(SQLERRM);
END IF;
RETURN FALSE;
END;
-- Проверяем тип строки и в любом случае присваиваем в CLOB

v_CLOB := empty_clob();

IF NVL(payload.text_body.small_value,'NO_DATA_FOUND') = 'NO_DATA_FOUND' THEN
v_CLOB := payload.text_body.large_value;
ELSE
v_CLOB := payload.text_body.small_value;
END IF;

COMMIT;

BRK01, добрый день!
Да требуется реализация стандартного механизма Reply to queue с корреляцией по MsgIDи CorrelID,
также хотелось дополнительно отправлять в сообщении кто его отправил и при чтении сообщений, также
фильтровать по данному параметру.

BRK01,
можете приложить пример кода на PL/SQL ?

BRK01, с точки зрения формирования запроса, я не вижу проблем:

header := sys.mgw_name_value_array_t(
sys.mgw_name_value_t.construct_integer('MGW_MQ_characterSet', '1208'),
sys.mgw_name_value_t.construct_integer('MGW_MQ_priority', '7'),
sys.mgw_name_value_t.CONSTRUCT_TEXT('MGW_MQ_replyToQueueName', 'REQEST_QU'),
sys.mgw_name_value_t.CONSTRUCT_TEXT('MGW_MQ_putApplicationName', 'SYSTEM_SPB')
sys.mgw_name_value_t.CONSTRUCT_RAW('MGW_MQ_messageId', '231'));

При получении ответа мне необходимо разобрать header, там я смогу увидеть ApplName, который отправил,
+ CorrelationId = 231 или нет ?
Буду благодарен за пример на PL/SQL?