公开(公告)号：US09391825B1

公开(公告)日：2016-07-12

申请号：US12410313

申请日：2009-03-24

Applicant: Jeff B. Beal ,  Alan Stuart Robbins ,  Jeromey R. Goetz ,  Brandon W. Porter ,  Grant A. M. McAlister ,  Joseph L. Ellsworth

Inventor： Jeff B. Beal ,  Alan Stuart Robbins ,  Jeromey R. Goetz ,  Brandon W. Porter ,  Grant A. M. McAlister ,  Joseph L. Ellsworth

IPC: G06F15/16 ,  H04L29/02

CPC classification number: H04L41/50 ,  H04L29/02 ,  H04L43/106 ,  H04L67/02 ,  H04L67/2804 ,  H04L67/325 ,  H04L69/28

Abstract: Various embodiments of a system and method for tracking service requests are described. Embodiments may include call tree generation logic configured to receive multiple request identifiers associated with a respective one of multiple service requests. Each given request identifier may include an origin identifier, a depth value, and a request stack comprising one or more interaction identifiers. The call tree generation logic may also be configured to, based on multiple request identifiers that each include an origin identifier associated with a particular root request, generating a data structure that specifies a hierarchy of services called to fulfill that particular root request. Based on one or more of the interaction identifiers and one or more of the depth values, the generated data structure may specify for each given service of the hierarchy: a parent service that called the given service, and one or more child services called by the given service.

Abstract translation: 描述用于跟踪服务请求的系统和方法的各种实施例。 实施例可以包括被配置为接收与多个服务请求中的相应一个相关联的多个请求标识符的呼叫树生成逻辑。 每个给定的请求标识符可以包括原始标识符，深度值和包括一个或多个交互标识符的请求堆栈。 呼叫树生成逻辑还可以被配置为基于多个请求标识符，每个请求标识符包括与特定根请求相关联的原始标识符，生成指定被称为满足该特定根请求的服务层级的数据结构。 基于一个或多个交互标识符和一个或多个深度值，生成的数据结构可以为层次结构的每个给定服务指定：称为给定服务的父服务，以及由该服务调用的一个或多个子服务 给予服务。

公开(公告)号：US08763013B2

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

申请号：US13594716

申请日：2012-08-24

Applicant: Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

Inventor： Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

IPC: G06F9/44 ,  G06F15/167

CPC classification number: H04L67/32 ,  G06F9/546 ,  G06F11/0709 ,  G06F11/0724 ,  G06F11/076 ,  G06F11/0766 ,  H04L67/02

Abstract: A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those proceeding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.

Abstract translation: 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是那些进行物理ACK级别指针，指定物理队列中的第一个未确认消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。

公开(公告)号：US08261286B1

公开(公告)日：2012-09-04

申请号：US12176222

申请日：2008-07-18

Applicant: Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

Inventor： Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

IPC: G06F9/46 ,  G06F15/16 ,  G06F11/00

CPC classification number: H04L67/32 ,  G06F9/546 ,  G06F11/0709 ,  G06F11/0724 ,  G06F11/076 ,  G06F11/0766 ,  H04L67/02

Abstract: A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.

Abstract translation: 经纪人可以被用作在生产者和消费者之间交换信息的中介。 代理可以从存储在持久存储器中的物理队列存储和分派消息。 更具体地，代理可以将从消息者接收到的物理队列的消息排队，并且可以将消息从物理队列分派到感兴趣的消费者。 代理可以进一步利用存储在瞬时存储器中的一个或多个逻辑队列来跟踪存储在持久存储器中的消息的状态。 当消息被分派到感兴趣的消费者并被确认时，代理从物理队列中删除已确认的消息。 删除的消息是指定物理队列中的第一个未确认消息的物理ACK级别指针之前的消息。 基于由逻辑队列维护的相应逻辑ACK级指针的相对位置，物理ACK级指针在物理队列中进行高级。

公开(公告)号：US10467568B1

公开(公告)日：2019-11-05

申请号：US12489960

申请日：2009-06-23

Applicant: Alan Stuart Robbins ,  Srikanth Satyanarayana ,  Richard M. Sears

Inventor： Alan Stuart Robbins ,  Srikanth Satyanarayana ,  Richard M. Sears

IPC: G06Q10/00 ,  G06Q10/06 ,  G06N20/00 ,  G06F21/60 ,  G06F16/9535

Abstract: Disclosed are various embodiments for scalable workflow processing. To this end, a workflow instance is placed in a queue accessible to a processor-based system, the queue being associated with a workflow. A workflow history associated with the workflow instance is applied to a decision application in response to a poll from the decision application, where the decision application is configured to determine a next action to be taken for the workflow instance. The next action to be taken for the workflow instance is initiated in the processor-based system based on a directive from the decision application generated based on the workflow history.

公开(公告)号：US20130024538A1

公开(公告)日：2013-01-24

申请号：US13594716

申请日：2012-08-24

Applicant: Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

Inventor： Maxim E. Fateev ,  Alan Stuart Robbins ,  Marvin M. Theimer

IPC: G06F15/167

CPC classification number: H04L67/32 ,  G06F9/546 ,  G06F11/0709 ,  G06F11/0724 ,  G06F11/076 ,  G06F11/0766 ,  H04L67/02

Abstract: A broker may be used as an intermediary to exchange messages between producers and consumers. The broker may store and dispatch messages from a physical queue stored in a persistent memory. More specifically, the broker may enqueue messages to the physical queue that are received from producers and may dispatch messages from the physical queue to interested consumers. The broker may further utilize one or more logical queues stored in transient memory to track the status of the messages stored in persistent memory. As messages are dispatched to and acknowledged by interested consumers, the broker deletes acknowledged messages from the physical queue. The messages deleted are those preceding a physical ACKlevel pointer that specifies the first non-acknowledged message in the physical queue. The physical ACKlevel pointer is advanced in the physical queue based on the relative position of corresponding logical ACKlevel pointers maintained by the logical queues.