iframe-proxy | Sunbelt Computer Software

History

46 lines (40 loc) · 1.7 KB

Raw

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

# AdvancedQueuingNotification.py

# This script demonstrates using advanced queuing notification. Once this

# script is running, use another session to enqueue a few messages to the

# "DEMO_BOOK_QUEUE" queue. This is most easily accomplished by running the

# ObjectAQ.py sample.

# This script requires cx_Oracle 6.4 and higher.

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

import cx_Oracle

import sample_env

import threading

import time

registered = True

def ProcessMessages(message):

global registered

print("Message type:", message.type)

if message.type == cx_Oracle.EVENT_DEREG:

print("Deregistration has taken place...")

registered = False

return

print("Queue name:", message.queueName)

print("Consumer name:", message.consumerName)

connection = cx_Oracle.connect(sample_env.get_main_connect_string(),

events=True)

sub = connection.subscribe(namespace=cx_Oracle.SUBSCR_NAMESPACE_AQ,

name="DEMO_BOOK_QUEUE", callback=ProcessMessages,

timeout=300)

print("Subscription:", sub)

print("--> Connection:", sub.connection)

print("--> Callback:", sub.callback)

print("--> Namespace:", sub.namespace)

print("--> Protocol:", sub.protocol)

print("--> Timeout:", sub.timeout)

while registered:

print("Waiting for notifications....")

time.sleep(5)

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

AdvancedQueuingNotification.py

Latest commit

History

AdvancedQueuingNotification.py

File metadata and controls