Method of using a plurality of subscriber types in managing a message queue of a database management system

• US 8,464,275 B2
• Filed: 06/19/2006
• Issued: 06/11/2013
• Est. Priority Date: 05/10/2006
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Surlaker, Kapil, Bhatt, Neerja
• Primary Examiner(s): Ho, Andy
• Assistant Examiner(s): Kraft, Shih-Wei
• Application Number:
  US11/471,406
• Publication Number:
  US 20070276914A1
• Time in Patent Office: 2,549 Days
• Field of Search: 719/313, 719/314, 719/318, 709201-203, 709/206, 709/223, 709/224, 709/228, 709/232, 709/237, 707 2- 5, 707/10, 707/100, 707/102, 707/104.1, 718/100, 718/102, 718/106
• US Class Current: 719/314
• CPC Class Codes: G06F 16/2358 Change logging, detection, and notification replication G06F16/27

Abstract

A method of using a plurality of subscriber types in managing a message queue of a database management system is described and provided. The method comprises creating a subscriber with a set of rules to the message queue. The subscriber is designated as one or more of the plurality of subscriber types. Moreover, an event notification registration representing a request to be notified if a message to the message queue satisfies the set of rules may be created. In response to a new message for enqueuing to the message queue, it is determined whether the new message satisfies the set of rules. If the new message satisfies the set of rules and if so determined by a triggered event notification registration, a notification is performed according to the triggered event notification registration. A requirement that a receiver of the notification dequeue the new message from the message queue depends on the subscriber type designation.

Claims

1. A method comprising:

creating, by executing instructions via a processor, a subscriber with a set of rules to a message queue of a database management system;

designating, by executing instructions via the processor, said subscriber as being of a first subscriber type that is to dequeue messages or of a second subscriber type that is not to dequeue messages, wherein specific access privileges to the message queue are created on a per-subscriber basis for subscribers designated as the first subscriber type and wherein subscribers designated as the second type avoid the need for creation of specific access privileges to said message queue in addition to said set of rules;

creating, by executing instructions via the processor, an event notification registration representing a request to be notified if a message to be enqueued to said message queue satisfies said set of rules;

in response to a new message for enqueuing to said message queue, determining, by executing instructions via the processor, whether said new message satisfies said set of rules;

when said new message satisfies said set of rules and if any event notification registration is triggered, performing, by executing instructions via the processor, a notification according to said triggered event notification registration,

wherein a dequeuing requirement that a receiver of said notification dequeue said new message from said message queue depends on whether said receiver is of the first subscriber type that is to dequeue messages, and

wherein said receiver of said notification is required to dequeue said new message from said message queue if said subscriber is designated as the first subscriber type.

2. The method as recited in claim 1 further comprising:

automatically dequeuing said new message from said message queue at an appropriate time.

3. The method as recited in claim 1 wherein said subscriber types include a public subscriber, and wherein, for the public subscriber, specific access privileges to the message queue on a per-subscriber basis are not created.

4. The method as recited in claim 1 wherein said subscriber types include a notification only subscriber.

5. The method as recited in claim 1 wherein said subscriber types include an ordinary subscriber, and wherein, for the ordinary subscriber, specific access privileges to the message queue are created on a per-subscriber basis.

6. The method as recited in claim 1, wherein a receiver of said notification is configured to not dequeue said new message from said message queue when said receiver is a subscriber designated as a type that is not to dequeue messages.

7. The method as recited in claim 1, said method further comprising:

dequeueing, by executing instructions via the processor, said new message from said message queue and sending, by a database management system, said new message to said receiver if said event notification registration is related to a subscriber of a type that is not to dequeue messages.

8. A non-transitory computer-readable medium comprising computer-executable instructions stored therein for performing a method of using a plurality of subscriber types in managing a message queue of a database management system, said method comprising:

creating a subscriber with a set of rules to said message queue;

designating said subscriber as one or more of said plurality of subscriber types, wherein a first subscriber type in the plurality of subscriber types is to dequeue messages and a second subscriber type in the plurality of subscriber types is not to dequeue messages, wherein specific access privileges to the message queue are created on a per-subscriber basis for subscribers designated as the first subscriber type and wherein subscribers designated as the second type avoid the need for creation of specific access privileges to said message queue in addition to said set of rules;

creating an event notification registration representing a request to be notified if a message to be enqueued to said message queue satisfies said set of rules;

in response to a new message for enqueuing to said message queue, determining whether said new message satisfies said set of rules;

if said new message satisfies said set of rules and if any event notification registration is triggered, performing a notification according to said triggered event notification registration, wherein a dequeuing requirement that a receiver of said notification dequeue said new message from said message queue depends on whether said receiver is of the first subscriber type that is to dequeue messages; and

wherein said receiver of said notification is required to dequeue said new message from said message queue if said subscriber is designated as the first subscriber type.

9. The computer-readable medium as recited in claim 8 further comprising:

automatically dequeuing said new message from said message queue at an appropriate time.

10. The computer-readable medium as recited in claim 8 wherein said subscriber types include a public subscriber, and wherein, for the public subscriber, specific access privileges to the message queue on a per-subscriber basis are not created.

11. The computer-readable medium as recited in claim 8 wherein said subscriber types include a notification only subscriber.

12. The computer-readable medium as recited in claim 8 wherein said subscriber types include an ordinary subscriber, and wherein, for the ordinary subscriber, specific access privileges to the message queue are created on a per-subscriber basis.

13. An apparatus comprising:

a memory comprising instructions stored therein; and

a processor for executing said instructions to perform a method of using a plurality of subscriber types in managing a message queue of a database management system, said method comprising;

creating a subscriber with a set of rules to said message queue;

designating said subscriber as one or more of said plurality of subscriber types, wherein a first subscriber type in the plurality of subscriber types is to dequeue messages and a second subscriber type in the plurality of subscriber types is not to dequeue messages, wherein specific access privileges to the message queue are created on a per-subscriber basis for subscribers designated as the first subscriber type and wherein subscribers designated as the second type avoid the need for creation of specific access privileges to said message queue in addition to said set of rules;

creating an event notification registration representing a request to be notified if a message to be enqueued to said message queue satisfies said set of rules;

in response to a new message for enqueuing to said message queue, determining whether said new message satisfies said set of rules;

if said new message satisfies said set of rules and if any event notification registration is triggered, performing a notification according to said triggered event notification registration, wherein a dequeuing requirement that a receiver of said notification dequeue said new message from said message queue depends on whether said receiver is of the first subscriber type that is to dequeue messages; and

wherein said receiver of said notification is required to dequeue said new message from said message queue if said subscriber is designated as the first subscriber type.

14. The apparatus as recited in claim 13 further comprising:

automatically dequeuing said new message from said message queue at an appropriate time.

15. The apparatus as recited in claim 13 wherein said subscriber types include a public subscriber, and wherein, for the public subscriber, specific access privileges to the message queue on a per-subscriber basis are not created.

16. The apparatus as recited in claim 13 wherein said subscriber types include a notification only subscriber.

17. The apparatus as recited in claim 13 wherein said subscriber types include an ordinary subscriber, and wherein, for the ordinary subscriber, specific access privileges to the message queue are created on a per-subscriber basis.

18. A method comprising:

maintaining, by executing instructions via a processor, a message queue and a list of subscribers to the message queue, each subscriber having a subscriber type and a set of rules,

designating, by executing instructions via the processor, each of said subscribers as being of a first subscriber type that is to dequeue messages or of a second subscriber type that is not to dequeue messages, wherein specific access privileges to the message queue are created on a per-subscriber basis for subscribers designated as the first subscriber type and wherein subscribers designated as the second type avoid the need for creation of specific access privileges to said message queue in addition to said set of rules;

maintaining, by executing instructions via the processor, a set of event notification registrations, each event notification registration identifying a subscriber in the list of subscribers to be notified if a message to be enqueued to the message queue satisfies the subscriber'"'"'s set of rules;

receiving, by executing instructions via the processor, a message to be enqueued to the message queue;

determining, by executing instructions via the processor, an event notification registration in the set of event notification registrations that is triggered by the receiving of the message;

determining, by executing instructions via the processor, whether the event notification registration identifies a subscriber that is of the type that is configured to dequeue messages; and

performing, by executing instructions via the processor, a notification according to the event notification registration;

wherein a dequeuing requirement that a receiver of said notification dequeue said new message from said message queue depends on whether said receiver is of the first subscriber type that is configured to dequeue messages, and

wherein said receiver of said notification is required to dequeue said new message from said message queue if said subscriber is designated as the first subscriber type.