iframe-proxy | Sunbelt Computer Software

History

47 lines (39 loc) · 1.64 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

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

# AdvancedQueuing sample.

# This script requires cx_Oracle 6.4 and higher.

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

from __future__ import print_function

import cx_Oracle

import SampleEnv

import threading

import time

registered = True

def callback(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(SampleEnv.GetMainConnectString(), events = True)

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

name = "BOOKS", callback = callback, 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