排队消息的并发处理

摘要

在流内执行排序的同时，提供对来自消息队列消息的可缩放、并发（即，并发）处理。因此能够遵守消息之间的依赖性。不要求用于确定哪些消息形成流的准则为消息分派器所知，消息分派器接收流名称并确定该指定流中的另一消息正在被处理。如果是这样，则分派器确定调取者是应暂时等待，还是应被给定先前被阻止且已变得可用于处理的不同消息，还是应被命令从消息队列取回不同的消息。

主权项

一种并发地处理来自消息队列的排队消息的流的计算机实现的方法，包括：接收用以分配来自所述消息队列的排队消息以由线程处理的请求，所述排队消息属于已标识的消息流；以及响应于确定属于已标识的所述消息流的另一消息当前不在被处理，分配所述排队消息以用于由所述线程处理。