Skip to content

Commit d0acef1

Browse files
matayalmatayal
authored
rename TEQ to TxEventQ (#609)
1 parent b6461dc commit d0acef1

39 files changed

+351
-311
lines changed

‎workshops/oracleAQ/qJava/src/main/java/com/examples/config/ConstantName.java‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ public class ConstantName {
88

99
//AQ- Point to Point
1010
public String aq_createTable = "JAVA_QUEUE_TABLE";
11-
public String aq_createQueue = "JAVA_QUEUE";
11+
public String aq_creaTxEventQueue = "JAVA_QUEUE";
1212

1313
public String aq_enqueueDequeueTable= "JAVA_ENQUEUE_DEQUEUE_QUEUE_TABLE";
1414
public String aq_enqueueDequeueQueue= "JAVA_ENQUEUE_DEQUEUE_QUEUE";
@@ -21,9 +21,9 @@ public class ConstantName {
2121
public String aq_pubSubQueue = "JAVA_AQ_PUBSUB_QUEUE";
2222
public String aq_pubSubSubscriber1 = "JAVA_AQ_PUBSUB_SUBSCRIBER1";
2323

24-
//TEQ- PUBSUB
25-
public String teq_pubSubQueue = "JAVA_TEQ_PUBSUB_QUEUE";
26-
public String teq_pubSubSubscriber1 = "JAVA_TEQ_PUBSUB_SUBSCRIBER1";
24+
//TxEventQ- PUBSUB
25+
public String TxEventQ_pubSubQueue = "JAVA_TxEventQ_PUBSUB_QUEUE";
26+
public String TxEventQ_pubSubSubscriber1 = "JAVA_TxEventQ_PUBSUB_SUBSCRIBER1";
2727

2828
//AQ- WORKFLOW
2929
public String aq_userQueueTable = "JAVA_AQ_USER_QUEUE_TABLE";
@@ -41,18 +41,18 @@ public class ConstantName {
4141
public String aq_applicationUserSubscriber = "JAVA_AQ_APPLICATION_USER_SUBS";
4242
public String aq_applicationDelivererSubscriber = "JAVA_AQ_APPLICATION_DELIVERER_SUBS";
4343

44-
//TEQ- WORKFLOW
45-
public String teq_userQueueName = "JAVA_TEQ_USER_QUEUE";
46-
public String teq_userApplicationSubscriber = "JAVA_TEQ_USER_APPLICATION_SUBS";
47-
public String teq_userDelivererSubscriber = "JAVA_TEQ_USER_DELIVERER_SUBS";
48-
49-
public String teq_delivererQueueName = "JAVA_TEQ_DELIVERER_QUEUE";
50-
public String teq_delivererApplicationSubscriber= "JAVA_TEQ_DELIVERER_APPLICATION_SUBS";
51-
public String teq_delivererUserSubscriber = "JAVA_TEQ_DELIVERER_USER_SUBS";
52-
53-
public String teq_applicationQueueName = "JAVA_TEQ_APPLICATION_QUEUE";
54-
public String teq_applicationUserSubscriber = "JAVA_TEQ_APPLICATION_USER_SUBS";
55-
public String teq_applicationDelivererSubscriber= "JAVA_TEQ_APPLICATION_DELIVERER_SUBS";
44+
//TxEventQ- WORKFLOW
45+
public String TxEventQ_userQueueName = "JAVA_TxEventQ_USER_QUEUE";
46+
public String TxEventQ_userApplicationSubscriber = "JAVA_TxEventQ_USER_APPLICATION_SUBS";
47+
public String TxEventQ_userDelivererSubscriber = "JAVA_TxEventQ_USER_DELIVERER_SUBS";
48+
49+
public String TxEventQ_delivererQueueName = "JAVA_TxEventQ_DELIVERER_QUEUE";
50+
public String TxEventQ_delivererApplicationSubscriber= "JAVA_TxEventQ_DELIVERER_APPLICATION_SUBS";
51+
public String TxEventQ_delivererUserSubscriber = "JAVA_TxEventQ_DELIVERER_USER_SUBS";
52+
53+
public String TxEventQ_applicationQueueName = "JAVA_TxEventQ_APPLICATION_QUEUE";
54+
public String TxEventQ_applicationUserSubscriber = "JAVA_TxEventQ_APPLICATION_USER_SUBS";
55+
public String TxEventQ_applicationDelivererSubscriber= "JAVA_TxEventQ_APPLICATION_DELIVERER_SUBS";
5656

5757

5858
}

‎workshops/oracleAQ/qNodejs/teq/nodeCreateTEQ.js‎

Lines changed: 0 additions & 70 deletions
This file was deleted.

‎workshops/oracleAQ/qNodejs/teq/nodeEnqDeqTEQ.js‎

Lines changed: 0 additions & 66 deletions
This file was deleted.

‎workshops/oracleAQ/qNodejs/teq/nodeCleanupTEQ.js‎ renamed to ‎workshops/oracleAQ/qNodejs/txEventQ/nodeCleanupTxEventQ.js‎

Lines changed: 17 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,17 @@
1-
const oracledb = require('oracledb');
1+
const oracledb = require("oracledb");
22

33
async function run() {
4-
54
let connection;
65

76
try {
87
const config = { connectString: process.env.DB_ALIAS, externalAuth: true };
9-
const connection = await oracledb.getConnection(config);
10-
11-
cleanUp(connection,"NODE_TEQ_ADT" );
12-
cleanUp(connection,"NODE_TEQ_RAW" );
13-
cleanUp(connection,"NODE_TEQ_JMS" );
14-
cleanUp(connection,"NODE_TEQ_JSON" );
8+
const connection = await oracledb.getConnection(config);
159

16-
17-
} catch (err) {
10+
cleanUp(connection, "NODE_TxEventQ_ADT");
11+
cleanUp(connection, "NODE_TxEventQ_RAW");
12+
cleanUp(connection, "NODE_TxEventQ_JMS");
13+
cleanUp(connection, "NODE_TxEventQ_JSON");
14+
} catch (err) {
1815
console.error(err);
1916
} finally {
2017
if (connection) {
@@ -29,20 +26,21 @@ async function run() {
2926
run();
3027

3128
async function cleanUp(conn, queueTable, queueName) {
32-
33-
await conn.execute(`
29+
await conn.execute(
30+
`
3431
BEGIN
35-
DBMS_AQADM.STOP_QUEUE( QUEUE_NAME => '`.concat(queueName).concat(`');
32+
DBMS_AQADM.STOP_QUEUE( QUEUE_NAME => '`.concat(queueName)
33+
.concat(`');
3634
END;`)
37-
);
38-
39-
await conn.execute(`
35+
);
36+
37+
await conn.execute(
38+
`
4039
BEGIN
4140
DBMS_AQADM.DROP_TRANSACTIONAL_QUEUE(
4241
QUEUE_NAME => '`.concat(queueName).concat(`',
4342
FORCE => TRUE
4443
);
4544
END;`)
46-
);
47-
48-
}
45+
);
46+
}

‎workshops/oracleAQ/qNodejs/txEventQ/nodeCreateTxEventQ.js‎

Lines changed: 101 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,101 @@
1+
const oracledb = require("oracledb");
2+
3+
async function run() {
4+
let connection;
5+
6+
try {
7+
const config = { connectString: process.env.DB_ALIAS, externalAuth: true };
8+
const connection = await oracledb.getConnection(config);
9+
10+
await connection.execute(
11+
"CREATE OR REPLACE TYPE NODE_TxEventQ_MESSAGE_TYPE AS OBJECT (NAME VARCHAR2(10),ADDRESS VARCHAR2(50))"
12+
);
13+
14+
createTxEventQ(
15+
connection,
16+
"NODE_TxEventQ_ADT",
17+
"NODE_TxEventQ_MESSAGE_TYPE",
18+
"SUBSCRIBER_NODE_TxEventQ_ADT"
19+
);
20+
createTxEventQ(
21+
connection,
22+
"NODE_TxEventQ_RAW",
23+
"RAW",
24+
"SUBSCRIBER_NODE_TxEventQ_RAW"
25+
);
26+
createTxEventQ(
27+
connection,
28+
"NODE_TxEventQ_JMS",
29+
"JMS",
30+
"SUBSCRIBER_NODE_TxEventQ_JMS"
31+
);
32+
createTxEventQ(
33+
connection,
34+
"NODE_TxEventQ_JSON",
35+
"JSON",
36+
"SUBSCRIBER_NODE_TxEventQ_JSON"
37+
);
38+
} catch (err) {
39+
console.error(err);
40+
} finally {
41+
if (connection) {
42+
try {
43+
await connection.close();
44+
} catch (err) {
45+
console.error(err);
46+
}
47+
}
48+
}
49+
}
50+
run();
51+
52+
async function createTxEventQ(conn, queueName, payload, subscriberName) {
53+
await conn.execute(
54+
`
55+
BEGIN
56+
DBMS_AQADM.CREATE_TRANSACTIONAL_EVENT_QUEUE(
57+
queue_name =>'`
58+
.concat(queueName)
59+
.concat(
60+
`',
61+
storage_clause =>null,
62+
multiple_consumers =>true,
63+
max_retries =>10,
64+
comment =>'Node.js Samples for TxEventQ',
65+
queue_payload_type =>'`
66+
)
67+
.concat(payload).concat(`',
68+
queue_properties =>null,
69+
replication_mode =>null
70+
);
71+
END;`)
72+
);
73+
74+
await conn.execute(
75+
`
76+
BEGIN
77+
DBMS_AQADM.START_QUEUE(
78+
queue_name=>'`.concat(queueName).concat(`',
79+
enqueue =>TRUE,
80+
dequeue=> True
81+
);
82+
END;`)
83+
);
84+
85+
await conn.execute(
86+
`
87+
DECLARE
88+
subscriber sys.aq$_agent;
89+
BEGIN
90+
DBMS_AQADM.add_subscriber(
91+
queue_name =>'`
92+
.concat(queueName)
93+
.concat(
94+
`',
95+
subscriber => sys.aq$_agent('`
96+
)
97+
.concat(subscriberName).concat(`', null ,0)
98+
);
99+
END;`)
100+
);
101+
}

0 commit comments

Comments
 (0)