Techniques for event filtering
First Claim
1. A method for event notification comprising:
- receiving, using a processor, a first notification at a filtering service module about a first event;
setting, using a processor, a timer to an amount of time in response to receiving the first notification about the first event;
waiting until an earlier occurrence of either receiving, by the filtering service module, a second notification of a second event prior to said amount of time elapsing, or expiration of said timer indicating that said amount of time has elapsed prior to the filtering service module receiving said second notification;
determining, using a processor, whether said amount of time has elapsed prior to receiving said second notification by the filtering service module or whether said second notification has been received by the filtering service module prior to said amount of time elapsing, wherein if said amount of time has elapsed prior to the filtering service module receiving the second notification, notification of said first event is provided by the filtering service module to a subscriber, and otherwise, if said second notification has been received by the filtering service module prior to said amount of time elapsing, resetting said timer and waiting for an occurrence of either the filtering service module receiving a next notification of an event or expiration of said timer indicating that said amount of time has elapsed since the filtering service module received a notification of an event occurrence, andwherein a plurality of notifications about a plurality of events are received by the filtering service module, a temporal distance between any two consecutive ones of the plurality of notifications received by the filtering service module is less than said amount of time, and said amount of time elapses after the filtering service module receives a last one of the plurality of notifications, the method further comprising;
firing, using a processor, an event notification from the filtering service module to said subscriber about only the last one of the plurality of notifications received by the filtering service module after said amount of time elapses without the filtering service module receiving a next notification of an event.
10 Assignments
0 Petitions
Accused Products
Abstract
Described are techniques for event notification. A first notification about a first event is received. A timer is set to an amount of time. Processing waits until an occurrence of either receiving a second notification of a second event or expiration of said timer indicating that the amount of time has lapsed. It is determined whether the amount of time has lapsed or whether the second notification has been received. If the expiration time has lapsed, notification of the first event is provided, and otherwise, if the second notification has been received prior to the amount of time lapsing, the timer is reset and processing waits for an occurrence of either receiving a next notification of an event or expiration of the timer indicating that the amount of time has lapsed.
17 Citations
16 Claims
-
1. A method for event notification comprising:
-
receiving, using a processor, a first notification at a filtering service module about a first event; setting, using a processor, a timer to an amount of time in response to receiving the first notification about the first event; waiting until an earlier occurrence of either receiving, by the filtering service module, a second notification of a second event prior to said amount of time elapsing, or expiration of said timer indicating that said amount of time has elapsed prior to the filtering service module receiving said second notification; determining, using a processor, whether said amount of time has elapsed prior to receiving said second notification by the filtering service module or whether said second notification has been received by the filtering service module prior to said amount of time elapsing, wherein if said amount of time has elapsed prior to the filtering service module receiving the second notification, notification of said first event is provided by the filtering service module to a subscriber, and otherwise, if said second notification has been received by the filtering service module prior to said amount of time elapsing, resetting said timer and waiting for an occurrence of either the filtering service module receiving a next notification of an event or expiration of said timer indicating that said amount of time has elapsed since the filtering service module received a notification of an event occurrence, and wherein a plurality of notifications about a plurality of events are received by the filtering service module, a temporal distance between any two consecutive ones of the plurality of notifications received by the filtering service module is less than said amount of time, and said amount of time elapses after the filtering service module receives a last one of the plurality of notifications, the method further comprising; firing, using a processor, an event notification from the filtering service module to said subscriber about only the last one of the plurality of notifications received by the filtering service module after said amount of time elapses without the filtering service module receiving a next notification of an event. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A system comprising a non-transitory computer readable medium including code stored thereon which, when executed, function as:
-
a publisher of event notifications; a message service that receives said event notifications from said publisher; a filtering service which receives said event notifications from said message service, said filtering service having a timer indicating an amount of time; a subscriber which receives a portion of said event notifications from said filtering service in accordance with subscription criteria, and wherein said filtering service further comprises code for; receiving a first event notification at said filtering service about a first event in accordance with said subscription criteria; setting said timer to said amount of time in response to receiving the first event notification about the first event; waiting until an earlier occurrence of either receiving, by the filtering service, a second event notification of a second event in accordance with said subscription criteria prior to said amount of time elapsing or expiration of said timer indicating that said amount of time has elapsed prior to the filtering service receiving the second event notification; determining whether said amount of time has elapsed prior to the filtering service receiving said second event notification or whether said second event notification has been received by the filtering service prior to said amount of time elapsing, wherein if said amount of time has elapsed prior to the filtering service receiving the second event notification, notification of said first event is provided by the filtering service to said subscriber, and otherwise, if said second event notification has been received by the filtering service prior to said amount of time elapsing, resetting said timer and waiting for an occurrence of either the filtering service receiving a next notification of an event or expiration of said timer indicating that said amount of time has elapsed since the filtering service received a notification of an event occurrence, and wherein a plurality of notifications about a plurality of events having said subscription criteria are received by the filtering service, a temporal distance between any two consecutive ones of the plurality of notifications received by the filtering service is less than said amount of time, and said amount of time elapses after the filtering service receives a last one of the plurality of notifications, the filtering service further comprising code for; firing an event notification from the filtering service to said subscriber about only the last one of the plurality of notifications received by the filtering service after said amount of time elapses without the filtering service receiving a next notification of an event. - View Dependent Claims (9, 10, 11, 12, 13)
-
-
14. A non-transitory computer readable medium comprising code stored thereon for event notification, the non-transitory computer readable medium comprising code for:
-
receiving, using a processor, a first notification at a filtering service module about a first event; setting, using a processor, a timer to an amount of time in response to receiving the first notification about the first event; waiting until an earlier occurrence of either receiving, by the filtering service module, a second notification of a second event prior to said amount of time elapsing, or expiration of said timer indicating that said amount of time has elapsed prior to the filtering service module receiving said second notification; determining, using a processor, whether said amount of time has elapsed prior to receiving said second notification by the filtering service module or whether said second notification has been received by the filtering service module prior to said amount of time elapsing, wherein if said amount of time has elapsed prior to the filtering service module receiving the second notification, notification of said first event is provided by the filtering service module to a subscriber, and otherwise, if said second notification has been received by the filtering service module prior to said amount of time elapsing, resetting said timer and waiting for an occurrence of either the filtering service module receiving a next notification of an event or expiration of said timer indicating that said amount of time has elapsed since the filtering service module received a notification of an event occurrence, and wherein a plurality of notifications about a plurality of events are received by the filtering service module, a temporal distance between any two consecutive ones of the plurality of notifications received by the filtering service module is less than said amount of time, and said amount of time elapses after the filtering service module receives a last one of the plurality of notifications, the method further comprising; firing, using a processor, an event notification from the filtering service module to said subscriber about only the last one of the plurality of notifications received by the filtering service module after said amount of time elapses without the filtering service module receiving a next notification of an event. - View Dependent Claims (15, 16)
-
Specification