Processing and ordering messages in partitions

A method of maintaining messaging order and load balancing asynchronous messages, the method comprising:

• placing, by a service bus component, a first message associated with a first session identifier (ID) into a first partition in a plurality of partitions;
• placing a second message associated with a second session ID into a second partition;
• determining that the first session ID is not associated with a previously created receiver component;
• creating a first receiver component, wherein the first receiver component is a task, which processes each message in a first set of messages in the first partition in a same order each message is received by the service bus component;
• locking the first partition to the first receiver component;
• caching the first receiver component and the first session ID on memory of the first node;
• determining that the second session ID is not associated with the previously created receiver component and the first receiver component;
• creating to a second receiver component, wherein the second receiver component is a task, which processes each message in a second set of messages in the second partition in the same order each message is received by the service bus component;
• locking the second partition to the second receiver component;
• caching the second receiver component and the second session ID on memory in the second node;
• terminating the first receiver component responsive to occurrence of a predetermined event;
• and
• creating a third receiver component associated with the first session ID responsive to receiving a third message associated with the first session ID, wherein the third receiver component is a task, which processes a set of messages associated with the first session ID, including the third message, following termination of the first receiver component.

One or more computer storage devices having computer-executable instructions stored thereon for maintaining messaging order and load balancing asynchronous messages, which, on execution by a computer, cause the computer to perform operations comprising:

• placing a first message associated with a first session identifier (ID) into a first partition and a second message associated with a second session ID into a second partition in a plurality of partitions, wherein asynchronous messages are placed into partitions based on a session ID associated with each message;
• creating a first receiver component, which is a task that processes each message in a first set of messages in the first partition in a same order each message is received by a service bus component;
• applying a first session ID lock on the first partition;
• caching the first receiver component and the first session ID on memory of the first node;
• creating a second receiver component which is a task that processes each message in a second set of messages in the second partition in the same order each message is received by the service bus component;
• applying a second session ID lock on the second partition;
• caching the second receiver component and the second session ID on memory of the second node;
• terminating the first receiver component responsive to an elapsed time since a last message associated with the first session ID is received exceeding a threshold wait time.