Message processing using dynamic load balancing queues in a messaging system
First Claim
1. A computer-implementable method for dynamically managing message queues in a dynamic message-oriented middleware environment, the dynamic message-oriented middleware environment comprising a plurality of message queues and a plurality of dynamic load balancing message queues, comprising:
- receiving a first source message associated with a first target;
generating a first dynamic load balancing message queue when a first message queue is determined not to be optimal, the first message queue associated with the first target, the first message queue comprising a first application message queue and at least one of a respective first queue listener and a respective first application queue consumer;
associating the first dynamic load balancing message queue with the first target;
enqueueing the first source message to the first dynamic load balancing message queue for processing by the first target, the enqueueing the first source message being performed via a message queue router, the message queue router enqueueing the first source message according to routing rules;
receiving a second source message associated with a second target;
generating a second dynamic load balancing message queue when a second message queue is determined not to be optimal, the second message queue associated with the second target, the second message queue comprising a second application message queue and at least one of a respective second queue listener and a second application queue consumer, the generating the second dynamic load balancing message queue being performed when at least one of a predetermined message queue contention threshold is reached and when a predetermined message queue backlog value is reached;
associating the second dynamic load balancing message queue with the second target;
enqueueing the second source message to the second dynamic load balancing message queue for processing by the second target; and
,performing a dynamic message queue management operation in the message-oriented middleware environment based upon the receiving the first source message, generating the first dynamic load balancing message queue, associating the first dynamic load balancing message queue, enqueueing the first source message, the receiving the second source message, generating the second dynamic load balancing message queue, associating the second dynamic load balancing message queue, and enqueueing the second source message, the dynamic message queue management operation being performed by a dynamic message queue management system, the dynamic message queue management system comprising a load balancer, the load balancer identifying and routing a message load to one of the first message queue, the second message queue, the first dynamic load balancing message queue and the second dynamic load balancing message queue, the load balancer comprising at least one of a business-specific load balancer and a domain-specific load balancer.
14 Assignments
0 Petitions
Accused Products
Abstract
A system, method, and computer-readable medium are disclosed for dynamically managing message queues to balance processing loads in a message-oriented middleware environment. A first source message associated with a first target is received, followed by generating a first dynamic load balancing message queue when a first message queue associated with the first target is determined to not be optimal. The first dynamic load balancing message queue is then associated with the first target, followed by enqueueing the first source message to the first dynamic load balancing message queue for processing by the first target.
20 Citations
15 Claims
-
1. A computer-implementable method for dynamically managing message queues in a dynamic message-oriented middleware environment, the dynamic message-oriented middleware environment comprising a plurality of message queues and a plurality of dynamic load balancing message queues, comprising:
-
receiving a first source message associated with a first target; generating a first dynamic load balancing message queue when a first message queue is determined not to be optimal, the first message queue associated with the first target, the first message queue comprising a first application message queue and at least one of a respective first queue listener and a respective first application queue consumer; associating the first dynamic load balancing message queue with the first target; enqueueing the first source message to the first dynamic load balancing message queue for processing by the first target, the enqueueing the first source message being performed via a message queue router, the message queue router enqueueing the first source message according to routing rules; receiving a second source message associated with a second target; generating a second dynamic load balancing message queue when a second message queue is determined not to be optimal, the second message queue associated with the second target, the second message queue comprising a second application message queue and at least one of a respective second queue listener and a second application queue consumer, the generating the second dynamic load balancing message queue being performed when at least one of a predetermined message queue contention threshold is reached and when a predetermined message queue backlog value is reached; associating the second dynamic load balancing message queue with the second target; enqueueing the second source message to the second dynamic load balancing message queue for processing by the second target; and
,performing a dynamic message queue management operation in the message-oriented middleware environment based upon the receiving the first source message, generating the first dynamic load balancing message queue, associating the first dynamic load balancing message queue, enqueueing the first source message, the receiving the second source message, generating the second dynamic load balancing message queue, associating the second dynamic load balancing message queue, and enqueueing the second source message, the dynamic message queue management operation being performed by a dynamic message queue management system, the dynamic message queue management system comprising a load balancer, the load balancer identifying and routing a message load to one of the first message queue, the second message queue, the first dynamic load balancing message queue and the second dynamic load balancing message queue, the load balancer comprising at least one of a business-specific load balancer and a domain-specific load balancer. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A system comprising:
-
a processor; a data bus coupled to the processor; and a non-transitory, computer-readable storage medium embodying computer program code, the non-transitory, computer-readable storage medium being coupled to the data bus, the computer program code interacting with a plurality of computer operations for dynamically managing message queues in a dynamic message-oriented middleware environment, the dynamic message-oriented middleware environment comprising a plurality of message queues and a plurality of dynamic load balancing message queues and comprising instructions executable by the processor and configured for; receiving a first source message associated with a first target; generating a first dynamic load balancing message queue when a first message queue is determined not to be optimal, the first message queue associated with the first target, the first message queue comprising a first application message queue and at least one of a respective first queue listener and a respective first application queue consumer; associating the first dynamic load balancing message queue with the first target; enqueueing the first source message to the first dynamic load balancing message queue for processing by the first target; and
,receiving a second source message associated with a second target; generating a second dynamic load balancing message queue when a second message queue is determined not to be optimal, the second message queue associated with the second target, the second message queue comprising a second application message queue and at least one of a respective second queue listener and a second application queue consumer, the generating the second dynamic load balancing message queue being performed when at least one of a predetermined message queue contention threshold is reached and when a predetermined message queue backlog value is reached; associating the second dynamic load balancing message queue with the second target; enqueueing the second source message to the second dynamic load balancing message queue for processing by the second target; and
,performing a dynamic message queue management operation in the message-oriented middleware environment based upon the receiving the first source message, generating the first dynamic load balancing message queue, associating the first dynamic load balancing message queue, enqueueing the first source message, the receiving the second source message, generating the second dynamic load balancing message queue, associating the second dynamic load balancing message queue, and enqueueing the second source message, the dynamic message queue management operation being performed by a dynamic message queue management system, the dynamic message queue management system comprising a load balancer, the load balancer identifying and routing a message load to one of the first message queue, the second message queue, the first dynamic load balancing message queue and the second dynamic load balancing message queue, the load balancer comprising at least one of a business-specific load balancer and a domain-specific load balancer. - View Dependent Claims (7, 8, 9, 10)
-
-
11. A non-transitory, computer-readable storage medium embodying computer program code for dynamically managing message queues in a dynamic message-oriented middleware environment, the dynamic message-oriented middleware environment comprising a plurality of message queues and a plurality of dynamic load balancing message queues, the computer program code comprising computer executable instructions configured for:
-
receiving a first source message associated with a first target; generating a first dynamic load balancing message queue when a first message queue is determined not to be optimal, the first message queue associated with the first target, the first message queue comprising a first application message queue and at least one of a respective first queue listener and a respective first application queue consumer; associating the first dynamic load balancing message queue with the first target; enqueueing the first source message to the first dynamic load balancing message queue for processing by the first target; and
,receiving a second source message associated with a second target; generating a second dynamic load balancing message queue when a second message queue is determined not to be optimal, the second message queue associated with the second target, the second message queue comprising a second application message queue and at least one of a respective second queue listener and a second application queue consumer, the generating the second dynamic load balancing message queue being performed when at least one of a predetermined message queue contention threshold is reached and when a predetermined message queue backlog value is reached; associating the second dynamic load balancing message queue with the second target; enqueueing the second source message to the second dynamic load balancing message queue for processing by the second target; and
,performing a dynamic message queue management operation in the message-oriented middleware environment based upon the receiving the first source message, generating the first dynamic load balancing message queue, associating the first dynamic load balancing message queue, enqueueing the first source message, the receiving the second source message, generating the second dynamic load balancing message queue, associating the second dynamic load balancing message queue, and enqueueing the second source message, the dynamic message queue management operation being performed by a dynamic message queue management system, the dynamic message queue management system comprising a load balancer, the load balancer identifying and routing a message load to one of the first message queue, the second message queue, the first dynamic load balancing message queue and the second dynamic load balancing message queue, the load balancer comprising at least one of a business-specific load balancer and a domain-specific load balancer. - View Dependent Claims (12, 13, 14, 15)
-
Specification