From b43b8df330b9c478a4efe9122de2b2dfcfb59583 Mon Sep 17 00:00:00 2001
From: Mikhail Chechnev <mim_@mail.ru>
Date: Sun, 16 Dec 2018 02:14:58 +0300
Subject: [PATCH] =?UTF-8?q?=D0=9E=D1=82=D0=B4=D0=B5=D0=BB=D1=8C=D0=BD?=
 =?UTF-8?q?=D1=8B=D0=B5=20=D1=84=D1=83=D0=BD=D0=BA=D1=86=D0=B8=D0=B8=20?=
 =?UTF-8?q?=D0=B4=D0=BB=D1=8F=20=D1=81=D1=87=D0=B8=D1=82=D1=8B=D0=B2=D0=B0?=
 =?UTF-8?q?=D0=BD=D0=B8=D1=8F=20BLOB=20=D0=B4=D0=B0=D0=BD=D0=BD=D1=8B?=
 =?UTF-8?q?=D1=85=20=D0=BE=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8=20(QUEUE=5F?=
 =?UTF-8?q?GET=5FMSG=20=D0=B8=20QUEUE=5FGET=5FRESP),=20=D0=B8=D1=81=D0=BA?=
 =?UTF-8?q?=D0=BB=D1=8E=D1=87=D0=B5=D0=BD=D0=B8=D0=B5=20BLOB-=D0=B4=D0=B0?=
 =?UTF-8?q?=D0=BD=D0=BD=D1=8B=D1=85=20=D0=BF=D0=BE=D0=B7=D0=B8=D1=86=D0=B8?=
 =?UTF-8?q?=D0=B8=20=D0=BE=D1=87=D0=B5=D1=80=D0=B5=D0=B4=D0=B8=20=D0=B8?=
 =?UTF-8?q?=D0=B7=20=D1=81=D1=82=D0=B0=D0=BD=D0=B4=D0=B0=D1=80=D1=82=D0=BD?=
 =?UTF-8?q?=D0=BE=D0=B9=20=D0=B2=D1=8B=D0=B4=D0=B0=D1=87=D0=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 db/PKG_EXS.pck | 52 ++++++++++++++++++++++++++++++++++++++++++++++----
 1 file changed, 48 insertions(+), 4 deletions(-)

diff --git a/db/PKG_EXS.pck b/db/PKG_EXS.pck
index e296160..f825087 100644
--- a/db/PKG_EXS.pck
+++ b/db/PKG_EXS.pck
@@ -89,7 +89,7 @@ create or replace package PKG_EXS as
   /* Константы - признак инкремента количества попыток исполнения позиции очереди */
   NQUEUE_EXEC_NO            constant number(1) := 0; -- Не исполнять
   NQUEUE_EXEC_YES           constant number(1) := 1; -- Исполнять
-
+  
   /* Константы - ожидаемый интерфейс процедуры обработки сообщения очереди на стороне БД */
   SPRC_RESP_ARGS            constant varchar2(80) := 'NIDENT,IN,NUMBER;NSRV_TYPE,IN,NUMBER;NEXSQUEUE,IN,NUMBER;'; -- Список параметров процедуры обработки
 
@@ -345,6 +345,13 @@ create or replace package PKG_EXS as
     RCQUEUE                 out sys_refcursor -- Курсор с изменённой позицией очереди
   );
 
+  /* Считывание данных результата обработки записи очереди */
+  procedure QUEUE_RESP_GET
+  (
+    NEXSQUEUE               in number,        -- Рег. номер записи очереди
+    RCQUEUE_RESP            out sys_refcursor -- Курсор с данными результата обработки записи очереди
+  );
+
   /* Установка результата обработки записи очереди */
   procedure QUEUE_RESP_SET
   (
@@ -353,6 +360,13 @@ create or replace package PKG_EXS as
     RCQUEUE                 out sys_refcursor -- Курсор с изменённой позицией очереди
   );
 
+  /* Считывание данных сообщения записи очереди */
+  procedure QUEUE_MSG_GET
+  (
+    NEXSQUEUE               in number,        -- Рег. номер записи очереди
+    RCQUEUE_MSG             out sys_refcursor -- Курсор с данными сообщения записи очереди
+  ); 
+  
   /* Установка сообщения записи очереди */
   procedure QUEUE_MSG_SET
   (
@@ -1316,8 +1330,6 @@ create or replace package body PKG_EXS as
                     NQUEUE_EXEC_STATE_ERR,
                     SQUEUE_EXEC_STATE_ERR) "sExecState",
              T.EXEC_MSG "sExecMsg",
-             T.MSG "blMsg",
-             T.RESP "blResp",
              T.EXSQUEUE "nQueueId"
         from EXSQUEUE     T,
              EXSSERVICEFN F,
@@ -1350,7 +1362,7 @@ create or replace package body PKG_EXS as
     /* Чистим буфер */
     RNLIST_BASE_CLEAR(NIDENT => NIDENT);
   end QUEUE_GET;
-
+  
   /* Проверка необходимости исполнения позиции очереди */
   function QUEUE_SRV_TYPE_SEND_EXEC_CHECK
   (
@@ -1478,6 +1490,22 @@ create or replace package body PKG_EXS as
     QUEUE_GET(NFLAG_SMART => 0, NEXSQUEUE => NEXSQUEUE, RCQUEUE => RCQUEUE);
   end QUEUE_EXEC_STATE_SET;
 
+  /* Считывание данных результата обработки записи очереди */
+  procedure QUEUE_RESP_GET
+  (
+    NEXSQUEUE               in number,        -- Рег. номер записи очереди
+    RCQUEUE_RESP            out sys_refcursor -- Курсор с данными результата обработки записи очереди
+  )
+  is
+    REXSQUEUE               EXSQUEUE%rowtype; -- Запись позиции очереди
+  begin
+    /* Считаем запись очереди */
+    REXSQUEUE := GET_EXSQUEUE_ID(NFLAG_SMART => 0, NRN => NEXSQUEUE);
+    /* Вернем данные в виде курсора */
+    open RCQUEUE_RESP for
+      select REXSQUEUE.RESP "blResp" from DUAL;
+  end QUEUE_RESP_GET;
+  
   /* Установка результата обработки записи очереди */
   procedure QUEUE_RESP_SET
   (
@@ -1496,6 +1524,22 @@ create or replace package body PKG_EXS as
     QUEUE_GET(NFLAG_SMART => 0, NEXSQUEUE => NEXSQUEUE, RCQUEUE => RCQUEUE);
   end QUEUE_RESP_SET;
 
+  /* Считывание данных сообщения записи очереди */
+  procedure QUEUE_MSG_GET
+  (
+    NEXSQUEUE               in number,        -- Рег. номер записи очереди
+    RCQUEUE_MSG             out sys_refcursor -- Курсор с данными сообщения записи очереди
+  )
+  is
+    REXSQUEUE               EXSQUEUE%rowtype; -- Запись позиции очереди
+  begin
+    /* Считаем запись очереди */
+    REXSQUEUE := GET_EXSQUEUE_ID(NFLAG_SMART => 0, NRN => NEXSQUEUE);
+    /* Вернем данные в виде курсора */
+    open RCQUEUE_MSG for
+      select REXSQUEUE.MSG "blMsg" from DUAL;
+  end QUEUE_MSG_GET;
+
   /* Установка сообщения записи очереди */
   procedure QUEUE_MSG_SET
   (