Scalable, parallel processing of messages while enforcing custom sequencing criteria
    3.
    发明授权
    Scalable, parallel processing of messages while enforcing custom sequencing criteria 失效
    可扩展的并行处理消息,同时实施自定义排序标准

    公开(公告)号:US08763012B2

    公开(公告)日:2014-06-24

    申请号:US13411583

    申请日:2012-03-04

    IPC分类号: G06F3/00 G06F15/16

    摘要: Scalable, parallel (i.e., concurrent) processing of messages is provided from a message queue, while at the same time enforcing sequencing within a stream. Dependencies among messages can therefore be respected. The criteria for determining which messages form a stream are not required to be known to the message dispatcher, which receives a stream name and determines whether another message in that named stream is already being processed. If so, the dispatcher determines whether the invoker should wait temporarily, or should be given a different message that was previously blocked and has now become available for processing, or should be instructed to retrieve a different message from the message queue.

    摘要翻译: 从消息队列提供消息的可扩展,并行(即并发)处理,同时在流内执行排序。 因此可以尊重信息之间的依赖关系。 用于确定哪些消息形成流的标准不需要为接收流名称并确定该命名流中的另一消息是否已被处理的消息分派器是已知的。 如果是这样,调度员确定调用者是否应该暂时等待,或者应该给出一个先前被阻止并且现在已经可用于处理的不同消息,或者应该被指示从消息队列中检索不同的消息。

    Scalable, parallel processing of messages while enforcing custom sequencing criteria

    公开(公告)号:US08756613B2

    公开(公告)日:2014-06-17

    申请号:US13244079

    申请日:2011-09-23

    IPC分类号: G06F3/00 G06F15/16

    摘要: Scalable, parallel (i.e., concurrent) processing of messages is provided from a message queue, while at the same time enforcing sequencing within a stream. Dependencies among messages can therefore be respected. The criteria for determining which messages form a stream are not required to be known to the message dispatcher, which receives a stream name and determines whether another message in that named stream is already being processed. If so, the dispatcher determines whether the invoker should wait temporarily, or should be given a different message that was previously blocked and has now become available for processing, or should be instructed to retrieve a different message from the message queue.

    Scalable, Parallel Processing of Messages While Enforcing Custom Sequencing Criteria
    5.
    发明申请
    Scalable, Parallel Processing of Messages While Enforcing Custom Sequencing Criteria 失效
    可扩展,并行处理消息,同时强制自定义排序标准

    公开(公告)号:US20130081063A1

    公开(公告)日:2013-03-28

    申请号:US13411583

    申请日:2012-03-04

    IPC分类号: G06F3/00

    摘要: Scalable, parallel (i.e., concurrent) processing of messages is provided from a message queue, while at the same time enforcing sequencing within a stream. Dependencies among messages can therefore be respected. The criteria for determining which messages form a stream are not required to be known to the message dispatcher, which receives a stream name and determines whether another message in that named stream is already being processed. If so, the dispatcher determines whether the invoker should wait temporarily, or should be given a different message that was previously blocked and has now become available for processing, or should be instructed to retrieve a different message from the message queue.

    摘要翻译: 从消息队列提供消息的可扩展,并行(即并发)处理,同时在流内执行排序。 因此可以尊重信息之间的依赖关系。 用于确定哪些消息形成流的标准不需要为接收流名称并确定该命名流中的另一消息是否已被处理的消息分派器是已知的。 如果是这样,调度员确定调用者是否应该暂时等待,或者应该给出一个先前被阻止并且现在已经可用于处理的不同消息,或者应该被指示从消息队列中检索不同的消息。

    Scalable, Parallel Processing of Messages While Enforcing Custom Sequencing Criteria

    公开(公告)号:US20130081062A1

    公开(公告)日:2013-03-28

    申请号:US13244079

    申请日:2011-09-23

    IPC分类号: G06F3/00 G06F9/46

    摘要: Scalable, parallel (i.e., concurrent) processing of messages is provided from a message queue, while at the same time enforcing sequencing within a stream. Dependencies among messages can therefore be respected. The criteria for determining which messages form a stream are not required to be known to the message dispatcher, which receives a stream name and determines whether another message in that named stream is already being processed. If so, the dispatcher determines whether the invoker should wait temporarily, or should be given a different message that was previously blocked and has now become available for processing, or should be instructed to retrieve a different message from the message queue.