iframe-proxy | Sunbelt Computer Software

History

58 lines (50 loc) · 1.73 KB

Raw

#------------------------------------------------------------------------------

# raw_aq.py

# This script demonstrates how to use advanced queuing with RAW data. It

# makes use of a RAW queue created in the sample setup.

# This script requires cx_Oracle 8.2 and higher.

#------------------------------------------------------------------------------

import cx_Oracle as oracledb

import sample_env

QUEUE_NAME = "DEMO_RAW_QUEUE"

PAYLOAD_DATA = [

"The first message",

"The second message",

"The third message",

"The fourth and final message"

]

# connect to database

connection = oracledb.connect(sample_env.get_main_connect_string())

cursor = connection.cursor()

# create queue

queue = connection.queue(QUEUE_NAME)

queue.deqoptions.wait = oracledb.DEQ_NO_WAIT

queue.deqoptions.navigation = oracledb.DEQ_FIRST_MSG

# dequeue all existing messages to ensure the queue is empty, just so that

# the results are consistent

while queue.deqone():

pass

# enqueue a few messages

print("Enqueuing messages...")

for data in PAYLOAD_DATA:

print(data)

queue.enqone(connection.msgproperties(payload=data))

connection.commit()

# dequeue the messages

print("\nDequeuing messages...")

while True:

props = queue.deqone()

if not props:

break

print(props.payload.decode())

connection.commit()

print("\nDone.")

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

raw_aq.py

Latest commit

History

raw_aq.py

File metadata and controls