High density hosting for messaging service

摘要

Aspects of the subject matter described herein relate migrating message for a messaging service. In aspects, a determination is made that messages need to be migrated based on a threshold being crossed. In response, an agent is instructed to migrate data associated with the messages to another location. The agent uses various factors to determine one or more queues to migrate. While a queue is being migrated, during a first portion of the migration, messages may be added to and removed from the queue as senders send new messages and receivers consume messages. During a second portion of the migration, the queue is frozen to disallow the queue to be used for receiving new messages and delivering queued messages. The migration may be orchestrated to attempt to achieve certain goals.

主权项

1. A method implemented at least in part by a computer, the method comprising:
receiving an instruction to migrate data of messages at a first messaging container to a second messaging container, the first and second messaging containers individually containing one or more queues each holding one or more messages; in response to the received instruction, copying the data of the messages in a queue associated with the first messaging container to the second messaging container while allowing the queue to be used by the first messaging container for receiving new messages and delivering queued messages; during the data copying, detecting whether a remaining un-copied portion of the data of messages in the queue is less than a threshold; and in response to determining that the remaining un-copied portion of the data of the messages in the queue is less than the threshold,
disallowing the queue to be used by the first messaging container for receiving any new messages and delivering any queued messages;copying the remaining un-copied portion of the data of the messages in the queue from the first messaging container to the second messaging container while the queue is disallowed to be used by the first messaging container for receiving any new messages and delivering any received messages; andallowing the queue to be used for receiving new messages and delivering queued messages after the remaining un-copied portion of the data is copied to the second messaging container.