APPS.XDP_ADAPTER_CORE_PIPE dependencies on DBMS_PIPE

Line 13: DBMS_PIPE.PURGE(p_ChannelName);

9: p_CleanReturn in varchar2 default 'Y')
10: is
11: begin
12:
13: DBMS_PIPE.PURGE(p_ChannelName);
14: if p_CleanReturn = 'Y' then
15: DBMS_PIPE.PURGE(GetReturnChannelName(p_ChannelName => CleanupPipe.p_ChannelName));
16: end if;
17:

Line 15: DBMS_PIPE.PURGE(GetReturnChannelName(p_ChannelName => CleanupPipe.p_ChannelName));

11: begin
12:
13: DBMS_PIPE.PURGE(p_ChannelName);
14: if p_CleanReturn = 'Y' then
15: DBMS_PIPE.PURGE(GetReturnChannelName(p_ChannelName => CleanupPipe.p_ChannelName));
16: end if;
17:
18: end CleanupPipe;
19:

Line 28: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_Message);

24: begin
25:
26: -- dbms_output.put_line(to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
27: -- dbms_output.put_line('Sending ' || p_Message || ' on ' || p_ChannelName);
28: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_Message);
29: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_ChannelName);
30: ReturnCode := DBMS_PIPE.SEND_MESSAGE
31: (SendPipedMessage.p_ChannelName, pv_AckTimeout);
32:

Line 29: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_ChannelName);

25:
26: -- dbms_output.put_line(to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
27: -- dbms_output.put_line('Sending ' || p_Message || ' on ' || p_ChannelName);
28: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_Message);
29: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_ChannelName);
30: ReturnCode := DBMS_PIPE.SEND_MESSAGE
31: (SendPipedMessage.p_ChannelName, pv_AckTimeout);
32:
33: -- dbms_output.put_line('After Sending... Return Code: ' || ReturnCode);

Line 30: ReturnCode := DBMS_PIPE.SEND_MESSAGE

26: -- dbms_output.put_line(to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
27: -- dbms_output.put_line('Sending ' || p_Message || ' on ' || p_ChannelName);
28: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_Message);
29: DBMS_PIPE.PACK_MESSAGE(SendPipedMessage.p_ChannelName);
30: ReturnCode := DBMS_PIPE.SEND_MESSAGE
31: (SendPipedMessage.p_ChannelName, pv_AckTimeout);
32:
33: -- dbms_output.put_line('After Sending... Return Code: ' || ReturnCode);
34: end SendPipedMessage;

Line 53: -- dbms_output.put_line('DBMS_PIPE.RECEIVE. Channel: ' || p_ChannelName || ' Timeout: ' || ActualTimeout);

49: end if;
50:
51:
52: -- dbms_output.put_line(to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
53: -- dbms_output.put_line('DBMS_PIPE.RECEIVE. Channel: ' || p_ChannelName || ' Timeout: ' || ActualTimeout);
54: p_ErrorCode := DBMS_PIPE.RECEIVE_MESSAGE
55: (ReceivePipedMessage.p_ChannelName, ActualTimeout);
56:
57: -- dbms_output.put_line('After read..: ' || to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));

Line 54: p_ErrorCode := DBMS_PIPE.RECEIVE_MESSAGE

50:
51:
52: -- dbms_output.put_line(to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
53: -- dbms_output.put_line('DBMS_PIPE.RECEIVE. Channel: ' || p_ChannelName || ' Timeout: ' || ActualTimeout);
54: p_ErrorCode := DBMS_PIPE.RECEIVE_MESSAGE
55: (ReceivePipedMessage.p_ChannelName, ActualTimeout);
56:
57: -- dbms_output.put_line('After read..: ' || to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
58: -- dbms_output.put_line('Error Code: ' || p_ErrorCode);

Line 60: if DBMS_PIPE.NEXT_ITEM_TYPE <> 0 then

56:
57: -- dbms_output.put_line('After read..: ' || to_char(sysdate, 'DD-MON-YYYY HH24:MI:SS'));
58: -- dbms_output.put_line('Error Code: ' || p_ErrorCode);
59: if p_ErrorCode = 0 then
60: if DBMS_PIPE.NEXT_ITEM_TYPE <> 0 then
61: -- dbms_output.put_line('Unpacking...');
62: DBMS_PIPE.UNPACK_MESSAGE(p_Message);
63: -- dbms_output.put_line('AFTER Unpacking...' || substr(p_Message,1,200));
64: else

Line 62: DBMS_PIPE.UNPACK_MESSAGE(p_Message);

58: -- dbms_output.put_line('Error Code: ' || p_ErrorCode);
59: if p_ErrorCode = 0 then
60: if DBMS_PIPE.NEXT_ITEM_TYPE <> 0 then
61: -- dbms_output.put_line('Unpacking...');
62: DBMS_PIPE.UNPACK_MESSAGE(p_Message);
63: -- dbms_output.put_line('AFTER Unpacking...' || substr(p_Message,1,200));
64: else
65: p_Message := null;
66: end if;