公开(公告)号：US07162512B1

公开(公告)日：2007-01-09

申请号：US09514460

申请日：2000-02-28

申请人： Neta Amit ,  Alexander Frank ,  Yifat Peled

发明人： Neta Amit ,  Alexander Frank ,  Yifat Peled

IPC分类号： G06F13/00

CPC分类号： G06F9/546 ,  Y10S707/99931

摘要： Guaranteed, exactly once delivery of messages is disclosed. In one embodiment, there is a sender and a receiver. In a sender transaction, the sender does the following: receives a message from a sender queue; generates a substantially unique identifier and an expiration time for the message; and, saves the identifier, the expiration time, and the message in a sender database. The sender then sends the identifier, the expiration time, and the message to the receiver. In a receiver transaction, the receiver then does the following: receives the identifier, the expiration time, and the message from a receiver queue; determines whether the message has expired based on the expiration time and determines whether the message is present in a receiver database by its identifier; and, upon determining that the message has not expired and is not present in the receiver database, stores the message in the receiver database, and performs actions associated with the message.

摘要翻译： 保证，一旦传递消息就被公开。 在一个实施例中，存在发送器和接收器。 在发件人事务中，发件人执行以下操作：从发送方队列接收消息; 生成消息的基本上唯一的标识符和到期时间; 并在发件人数据库中保存标识符，到期时间和消息。 然后发送方将标识符，到期时间和消息发送给接收方。 在接收机事务中，接收者然后执行以下操作：从接收器队列接收标识符，到期时间和消息; 基于到期时间确定消息是否已经过期，并通过其标识确定消息是否存在于接收者数据库中; 并且在确定消息尚未到期并且不存在于接收器数据库中时，将消息存储在接收器数据库中，并且执行与该消息相关联的动作。

公开(公告)号：US06968556B1

公开(公告)日：2005-11-22

申请号：US09504531

申请日：2000-02-15

申请人： Ilan Caron ,  Raphael Renous ,  Yifat Peled ,  James Simpson

发明人： Ilan Caron ,  Raphael Renous ,  Yifat Peled ,  James Simpson

IPC分类号： G06F3/00 ,  G06F9/44 ,  G06F9/46 ,  G06F13/00

CPC分类号： G06F9/542 ,  G06F9/466 ,  G06F9/546 ,  G06F2209/544

摘要： Automatic message-based module invocation within a transactional message system is described. The modules can be software components, executable program files, etc. In one embodiment, a system includes one or more queues, a trigger store, and a trigger service. Each queue is capable of receiving messages. The trigger store includes one or more triggers, where each trigger is associated with a queue, and has associated therewith one or more rules, where each rule has a condition and an action. The trigger service is designed to, upon receipt of a message in a queue, check the condition of each rule of each trigger associated with the queue, to determine if the message satisfies the rule's condition. If such satisfaction occurs, then the action of the rule is performed, which can include invocation of a module. The rules may be short-circuit rules, non-destructive rules, and/or destructive rules, and may be checked in either a concurrent or serial manner.

摘要翻译： 描述事务消息系统内基于消息的自动消息模块调用。 模块可以是软件组件，可执行程序文件等。在一个实施例中，系统包括一个或多个队列，触发存储和触发服务。 每个队列都能够接收消息。 触发器存储包括一个或多个触发器，其中每个触发器与队列相关联，并且具有与其相关联的一个或多个规则，其中每个规则具有条件和动作。 触发服务被设计为在接收到队列中的消息时，检查与队列相关联的每个触发器的每个规则的条件，以确定消息是否满足规则的条件。 如果发生这种满足，则执行规则的操作，其可以包括调用模块。 规则可以是短路规则，非破坏性规则和/或破坏性规则，并且可以以并发或串行方式来检查。