Subsystem-specific notification framework for handling adjustments to batch requests
A computing environment can provide subsystem-specific notifications of adjustments to a batch of requests. For example, a system can receive an alert indicating an occurrence of an event involving an adjustment to a submitted batch of requests. The system can identify a set of subsystems from a group of subsystems to notify of the occurrence of the event. Each subsystem in the set of subsystems can be configured to receive notifications from a corresponding message queue of a group of message queues. The system can, for each message queue of the group of message queues, customize a subsystem-specific notification of the occurrence of the event. The subsystem-specific notification can be formatted according to a formatting criterion for a corresponding subsystem. For each message queue of the group of message queues, the system can publish the subsystem-specific notification to the message queue for transmission to the corresponding subsystem.
1 . A method for handling adjustments to batch requests, the method comprising:
receiving, by a queue handler of a batch-adjustment notification framework, an alert from a batch processing framework indicating an adjustment to at least one request within a previously submitted batch of requests, wherein the adjustment is applied to the at least one request by the batch processing framework in response to identifying a problem with the at least one request while processing the at least one request, and wherein the adjustment is configured to address the problem with the at least one request;
identifying, by the queue handler, a set of subsystems from a plurality of subsystems to notify of the adjustment, wherein each subsystem in the set of subsystems is configured to receive notifications from a corresponding message queue of a plurality of message queues, wherein the set of subsystems is different from the batch processing framework, and wherein the identifying includes the queue handler comparing tasks associated with the adjustment to tasks that each subsystem can perform; and
for each message queue of the plurality of message queues:
customizing, by the queue handler, a subsystem-specific notification of the adjustment, the subsystem-specific notification being formatted according to a formatting criteria for a corresponding subsystem;
publishing, the subsystem-specific notification to the message queue for transmission to the corresponding subsystem; and
transmitting the subsystem-specification notification from the message queue to the corresponding subsystem, wherein a subsystem of the set of subsystems is configured to receive a corresponding system-specific notification from a message queue of the plurality of message queues and responsively execute a task configured to prevent recurrence of the problem in relation to the at least one request or another future request.
2 . The method of claim 1 , wherein the adjustment comprises a cancellation of the at least one request in the previously submitted batch of requests.
3 . The method of claim 1 , wherein identifying the set of subsystems comprises identifying the set of subsystems based on the adjustment.
4 . The method of claim 1 , wherein each subsystem of the set of subsystems is configured to automatically perform at least one task in response to receiving the subsystem-specific notification about the adjustment from its corresponding message queue, wherein the at least one task is configured to avoid the recurrence of the problem in relation to the at least one request or one or more future requests.
5 . The method of claim 1 , further comprising:
publishing each subsystem-specific notification to each message queue in a sequential order, the sequential order being determined based on a predefined priority associated with the set of subsystems.
6 . The method of claim 1 , further comprising customizing at least one subsystem-specific notification for at least one message queue corresponding to at least one subsystem of the set of subsystems by:
retrieving additional data associated with the adjustment; and
adding the additional data to the at least one subsystem-specific notification.
7 . The method of claim 1 , wherein at least one subsystem in the set of subsystems is external to a network associated with a notification framework.
8 . A system for handling adjustments to batch requests, the system comprising:
one or more processing devices; and
a memory that includes instructions executable by the one or more processing devices to perform operations comprising:
receiving, by a queue handler of a batch-adjustment notification framework, an alert from a batch processing framework indicating an adjustment to at least one request within a previously submitted batch of requests, wherein the adjustment is applied to the at least one request by the batch processing framework in response to identifying a problem with the at least one request while processing the at least one request, and wherein the adjustment is configured to address the problem with the at least one request;
identifying, by the queue handler, a set of subsystems from a plurality of subsystems to notify of the adjustment, wherein each subsystem in the set of subsystems is configured to receive notifications from a corresponding message queue of a plurality of message queues, wherein the set of subsystems is different from the batch processing framework, and wherein the identifying includes the queue handler comparing tasks associated with the adjustment to tasks that each subsystem can perform; and
for each message queue of the plurality of message queues:
customizing, by the one or more processors queue handler, a subsystem-specific notification of the adjustment, the subsystem-specific notification being formatted according to a formatting criteria for a corresponding subsystem;
publishing, by the one or more processors, the subsystem-specific notification to the message queue for transmission to the corresponding subsystem; and
transmitting the subsystem-specification notification from the message queue to the corresponding subsystem, wherein a subsystem of the set of subsystems is configured to receive a corresponding system-specific notification from a message queue of the plurality of message queues and responsively execute a task configured to prevent recurrence of the problem in relation to the at least one request or another future request.
9 . The system of claim 8 , wherein the adjustment comprises a return of the at least one request in the previously submitted batch of requests.
10 . The system of claim 8 , wherein the operation of identifying the set of subsystems comprises identifying the set of subsystems based on the adjustment.
11 . The system of claim 8 , wherein each subsystem of the set of subsystems is configured to automatically perform at least one task in response to receiving the subsystem-specific notification about the adjustment from its corresponding message queue.
12 . The system of claim 8 , the operations further comprising:
publishing each subsystem-specific notification to each message queue in a sequential order, the sequential order being determined based on a predefined priority associated with the set of subsystems.
13 . The system of claim 8 , the operations further comprising customizing at least one subsystem-specific notification for at least one message queue corresponding to at least one subsystem of the set of subsystems by:
retrieving additional data associated with the adjustment; and
adding the additional data to the at least one subsystem-specific notification.
14 . A non-transitory computer-readable medium comprising instructions that are executable by one or more processing devices for causing the one or more processing devices to perform operations of handling adjustments to batch requests, the operations comprising:
receiving, by a queue handler of a batch-adjustment notification framework, an alert from a batch processing framework indicating an adjustment to at least one request within a previously submitted batch of requests, wherein prior to the operation of receiving the alert, the batch processing framework is configured to:
apply the adjustment to the at least one request as a result of identifying a problem with the at least one request while processing the at least one request, wherein the adjustment is configured to address the problem with the at least one request; and
based on applying the adjustment to the at least one request, transmit the alert indicating the adjustment;
identifying, by the queue handler, a set of subsystems from a plurality of subsystems to notify of the adjustment, wherein each subsystem in the set of subsystems is configured to receive notifications from a corresponding message queue of a plurality of message queues, wherein the set of subsystems is different from the batch processing framework, and wherein the identifying includes the queue handler comparing tasks associated with the adjustment to tasks that each subsystem can perform;
for each message queue of the plurality of message queues:
customizing, by the one or more processors queue handler, a subsystem-specific notification of the adjustment, the subsystem-specific notification being formatted according to a formatting criteria for a corresponding subsystem;
publishing, by the one or more processors, the subsystem-specific notification to the message queue for transmission to the corresponding subsystem; and
transmitting the subsystem-specification notification from the message queue to the corresponding subsystem, wherein a subsystem of the set of subsystems is configured to receive a corresponding system-specific notification from a message queue of the plurality of message queues and responsively execute a task configured to prevent recurrence of the problem in relation to the at least one request or another future request.
15 . The non-transitory computer-readable medium of claim 14 , wherein the adjustment comprises a change to a value of the at least one request in the previously submitted batch of requests.
16 . The non-transitory computer-readable medium of claim 14 , wherein the set of subsystems is identified based on the adjustment at least in part by: accessing a database that correlates subsystems to tasks executable by the subsystems;
identifying a set of tasks, in the database, associated with the adjustment;
determining that the set of subsystems are correlated, in the database, to the set of tasks; and
based on determining that the set of subsystems are correlated in the database to the set of tasks, selecting the set of subsystems from the database to notify of the adjustment.
17 . The non-transitory computer-readable medium of claim 14 , wherein each subsystem of the set of subsystems is configured to automatically select at least one task based on the problem and perform the at least one task in response to receiving the subsystem-specific notification about the adjustment from its corresponding message queue.
18 . The non-transitory computer-readable medium of claim 14 , wherein:
the alert indicating the adjustment is received from the batch processing framework only after expiration of a predetermined grace period following submission of the batch of requests;
the adjustment comprises a return of the at least one request due to an account associated with the at least one request being inactive;
customizing the subsystem-specific notification for the corresponding subsystem involves adding additional data not present in the alert to the subsystem-specific notification, the additional data including at least one of a phone number or an Internet Protocol (IP) address associated with the at least one request; and
the corresponding subsystem is configured to use the additional data to perform an authentication check before updating a database based on the returned request.
19 . The non-transitory computer-readable medium of claim 14 , wherein the at least one request is an automatically recurring request, and wherein the task executed by the subsystem includes modifying a parameter of the automatically recurring request to prevent a future submission of the automatically recurring request from triggering the problem.
20 . The non-transitory computer-readable medium of claim 14 , wherein the task executed by the subsystem includes modifying and resubmitting the at least one request as part of a new batch of requests to the batch processing framework.