OracleAQ workshop: Added JSON payload to TEQ (#355)

* update oracleAQ

* update homeDirectory

* update code

* update oracleAQ

* update code

* updated AQ for rule based

* update

* updated code

* update oracleAQ

* update oracleAQ

* update code for Chetan test

* updateAQ

* update oracleAQ

* update oracleAQ

* update code changes

* update oracleAQ

* update oracleAQ

* update oracleAQ

* remove killall java

* remove .classpath, .factorypath, .project

* update oracleAQ

* added JSON to TEQ

Author: matayal

workshops/oracleAQ/dequeueTEQ.sql

@@ -45,4 +45,28 @@ BEGIN
     COMMIT; 
 END;
 /
+
+--Dequeue from JSON TEQ
+DECLARE
+    dequeue_options     dbms_aq.dequeue_options_t;
+    message_properties  dbms_aq.message_properties_t;
+    message_handle      RAW(16);
+    message             JSON;
+
+BEGIN
+    dequeue_options.dequeue_mode  := DBMS_AQ.REMOVE;
+    dequeue_options.wait          := DBMS_AQ.NO_WAIT;
+    dequeue_options.navigation    := DBMS_AQ.FIRST_MESSAGE;           
+    dequeue_options.consumer_name := 'teqBasicJsonSubscriber';
+
+DBMS_AQ.DEQUEUE(
+        queue_name         => 'jsonType_TEQ',
+        dequeue_options    => dequeue_options,
+        message_properties => message_properties,
+        payload            => message,
+        msgid              => message_handle);
+  dbms_output.put_line(json_serialize(message));
+ COMMIT;
+END;
+/
 EXIT;

workshops/oracleAQ/enqueueTEQ.sql

@@ -39,4 +39,28 @@ BEGIN
     COMMIT;
 END;
 /
+-- Enqueue for JSON Message
+DECLARE
+enqueue_options    dbms_aq.enqueue_options_t;
+message_properties dbms_aq.message_properties_t;
+message_handle     RAW(16);
+message            json;
+BEGIN
+  message:= json('
+        {
+        "ORDERID":12345, 
+        "USERNAME":"name"  
+        }');
+  message_properties.correlation := 'teqBasicJsonSubscriber';
+
+DBMS_AQ.ENQUEUE(
+     queue_name           => 'jsonType_TEQ',           
+     enqueue_options      => enqueue_options,       
+     message_properties   => message_properties,     
+     payload              => message,               
+     msgid                => message_handle);
+   dbms_output.put_line(json_serialize(message));
+   COMMIT;
+END;
+/
 EXIT;