Home
Extending HCL OneDB™Beyond standard relational database objects, HCL OneDB™ can be extended to handle specialized data types, access methods, routines, and other objects. HCL OneDB™ includes many built-in extensions that are fully integrated in the database server. HCL OneDB™ also provides DataBlade® modules, which are packages of extended database objects for a particular purpose and that are installed separately from the database server. Alternatively, you can create your own user-defined objects for HCL OneDB™.
HCL OneDB™ extensions and DataBlade® modulesThese topics describe how to use built-in database extensions and separately installed DataBlade® modules.
Database Extensions User's GuideThe HCL OneDB™ Database Extensions User's Guide explains how to use the database extensions that come with HCL OneDB™: Large Object Locator, MQ messaging, binary data types, basic text search, node data type, HCL OneDB™ web feature service for Geospatial Data, and SQL packages.
MQ Messaging (WMQ) messaging products provide an infrastructure for distributed, asynchronous communication of data in a distributed, heterogeneous environment. The WMQ message queue allows you to easily exchange information across platforms.
About MQ messagingYou can use either functions or tables to communicate between a database server application and the queue.
VerificationAfter completely the necessary configuration, verify that MQ messaging is working correctly.
Publish and subscribe to a queuePublishing and subscribing to a queue is an effective way of exchanging information between multiple users.
Subscribe to a queueTo subscribe to a queue, use the MQSubscribe() function.

Subscribe to a queue

To subscribe to a queue, use the MQSubscribe() function.

The following example shows how a database application subscribes to a queue to receive messages for a topic named Weather:

   --- before subscribe
   Topic: MQ/TIMESERIES.QUEUE.MANAGER           /StreamSupport
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*

BEGIN WORK;

EXECUTE FUNCTION MQSubscribe('AMT.SAMPLE.SUBSCRIBER', 'AMT.SAMPLE.PUB.SUB.POLICY', 
'Weather');

(expression)           1

1 row(s) retrieved.

   --- after subscribe
   Topic: MQ/TIMESERIES.QUEUE.MANAGER           /StreamSupport
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*
   Topic: Weather
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*
   Topic: MQ/S/TIMESERIES.QUEUE.MANAGER         /Subscribers/Identities/*

COMMIT WORK;