System and method for messaging
    1.
    发明授权
    System and method for messaging 有权
    消息的系统和方法

    公开(公告)号:US08631418B2

    公开(公告)日:2014-01-14

    申请号:US11297550

    申请日:2005-12-08

    IPC分类号: G06F3/00

    CPC分类号: G06F9/546

    摘要: A system and method for messaging in which, when a connection to a queue manager (220) is established, the queue manager allocates a Connection Identifier from the same name space (300) as Message Identifiers and returns this information (400) to the user. The user can then use this Connection Identifier as a Correlation Identifier, safe in the knowledge that it will not clash with any system generated Message Identifier or Correlation Identifier. A secondary benefit to this allocation scheme is that if a shared reply queue suffers from a build-up of messages then the Correlation Identifier in those messages can be used to identify the application expected to receive those messages.

    摘要翻译: 一种用于消息传递的系统和方法,其中当建立与队列管理器(220)的连接时,所述队列管理器从与消息标识符相同的名称空间(300)分配连接标识符,并将该信息(400)返回给用户 。 然后,用户可以使用此连接标识符作为相关标识符,安全的是它不会与任何系统生成的消息标识符或相关标识符冲突。 这种分配方案的次要好处是,如果共享应答队列受到消息的建立的影响,那么这些消息中的相关标识符可用于标识预期接收到这些消息的应用程序。

    Persistent messaging in a transaction processing environment
    3.
    发明授权
    Persistent messaging in a transaction processing environment 有权
    在事务处理环境中的持久消息传递

    公开(公告)号:US07240349B2

    公开(公告)日:2007-07-03

    申请号:US10324673

    申请日:2002-12-20

    IPC分类号: G06F9/46

    CPC分类号: G06F9/546 G06F9/466

    摘要: A method and computer program product is provided for sending a persistent message in a transaction-enabled messaging and queuing system. A message queue manager is responsible for transferring messages from a sender program to a receiving program via a message queue. A message is sent from the sender program to the message queue manager. The message is defined to permit the message queue manager to select whether to treat the message transactionally or non-transactionally.

    摘要翻译: 提供了一种方法和计算机程序产品,用于在启用事务的消息和排队系统中发送持久消息。 消息队列管理器负责通过消息队列将消息从发送者程序传送到接收程序。 从发送程序发送消息到消息队列管理器。 该消息被定义为允许消息队列管理器选择是事务处理还是非事务处理消息。

    Method and apparatus for controlling access by a plurality of concurrently operating processes to a resource
    4.
    发明授权
    Method and apparatus for controlling access by a plurality of concurrently operating processes to a resource 失效
    用于控制多个同时操作的进程对资源的访问的方法和装置

    公开(公告)号:US06678802B2

    公开(公告)日:2004-01-13

    申请号:US09900227

    申请日:2001-07-06

    IPC分类号: G06F1300

    CPC分类号: G06F9/5016 G06F13/14

    摘要: The invention relates to controlling access by a plurality of concurrently operating processes to a resource. An area of storage is allocated and a pre-determined number of slots defined therein. Responsive to a request by one of the processes for shared access to the resource, a determination is made as to whether to allocate shared access, and if so, the requesting process is allocated shared access upon the acquisition of one of the storage slots. Responsive to a request by one of the processes for exclusive access to the resource, a determination is made as to whether to allocate exclusive access, and if so exclusive access is allocated upon the acquisition of all of the storage slots.

    摘要翻译: 本发明涉及通过多个并行操作过程来控制对资源的访问。 分配存储区域和在其中定义的预定数量的时隙。 响应于用于共享访问资源的过程之一的请求,确定是否分配共享访问,并且如果是,则在获取存储时隙之一时向所述请求进程分配共享访问。 响应于对资源的独占访问的一个进程的请求,确定是否分配独占访问,并且如果在获取所有存储时隙时分配了这样的排他性访问。

    Publishing documents in a publish/subscribe data processing system
    5.
    发明授权
    Publishing documents in a publish/subscribe data processing system 有权
    在发布/订阅数据处理系统中发布文档

    公开(公告)号:US08732228B2

    公开(公告)日:2014-05-20

    申请号:US11282047

    申请日:2005-11-17

    IPC分类号: G06F15/16

    CPC分类号: G06F17/30011

    摘要: Documents are published in a publish subscribe data processing system. A first document to be published may have an associated topic. The first document is retained as a retained document. A second document to be published is retained as the retained document in response to receiving the second document before a predetermined time interval has passed. A copy of the second document is sent to a subscriber of the topic. A copy of the retained document is sent to the subscriber of the topic in response to a determination that the predetermined time interval has passed.

    摘要翻译: 文件发布在发布订阅数据处理系统中。 要发布的第一个文档可能有一个相关的主题。 第一份文件保留为保留文件。 在预定的时间间隔过去之前,将要发布的第二个文档作为保留的文档被保留以响应于接收第二个文档。 将第二份文件的副本发送给该主题的订阅者。 响应于已经经过预定时间间隔的确定,保留的文档的副本被发送到主题的订户。

    Method and system of committing operations of a synchronized transaction
    6.
    发明授权
    Method and system of committing operations of a synchronized transaction 有权
    提交同步事务操作的方法和系统

    公开(公告)号:US08606833B2

    公开(公告)日:2013-12-10

    申请号:US11295974

    申请日:2005-12-07

    IPC分类号: G06F17/30

    CPC分类号: G06F9/466

    摘要: A method and system for combined commit transaction request and subsequent operation request for committing the operations of a synchronized transaction by one or more applications (301, 4001, 501) on a resource manager (302, 402, 502). The method comprises: receiving a combined request (310, 410, 510) for an operation and a request to commit any outstanding synchronized transaction; committing the outstanding transaction (311, 414, 512); and processing (313, 413, 517) the requested operation outside the outstanding transaction. For example, in an asynchronous messaging process, the combined request specifies an option in a get operation request to commit any outstanding units of work prior to carrying out the get operation.

    摘要翻译: 一种用于组合提交事务请求和随后的操作请求的方法和系统,用于通过资源管理器(302,402,502)上的一个或多个应用(301,4001,501)提交同步事务的操作。 该方法包括:接收用于操作的组合请求(310,410,510)以及提交任何未完成的同步事务的请求; 承诺未偿还交易(311,414,512); 以及处理(313,413,517)未完成交易之外的所请求的操作。 例如,在异步消息传递过程中,组合请求在获取操作请求中指定在执行获取操作之前提交任何未完成的工作单元的选项。

    Inherited transactions in asynchronous messaging
    8.
    发明授权
    Inherited transactions in asynchronous messaging 有权
    异步消息传递中的继承事务

    公开(公告)号:US07757119B2

    公开(公告)日:2010-07-13

    申请号:US11462748

    申请日:2006-08-07

    IPC分类号: G06F11/00

    摘要: A method and system of inherited transactions in an asynchronous messaging are provided. A producer requests a message put operation in a transaction. A consumer carries out a get operation with the option to inherit the transaction of the put operation. In an inherited transaction, the consumer's transaction will not commit until the transaction it has inherited from commits. Work performed in the producer's transaction is visible to the consumer, but work performed in the consumer's transaction is not visible to the producer preserving asynchronous messaging semantics. A transaction hierarchy results and only the net effect of transaction hierarchy is hardened to non-volatile storage.

    摘要翻译: 提供了异步消息传递中的继承事务的方法和系统。 生产者在事务中请求消息输入操作。 消费者执行获取操作,并具有继承put操作的交易的选项。 在继承的事务中,消费者的事务将不会提交,直到它从提交继承的事务为止。 在生产者的交易中执行的工作对于消费者是可见的,但是在消费者的交易中执行的工作对于维护异步消息传递语义的生产者来说是不可见的。 事务层次结构,只有事务层次结构的净效应才能硬化到非易失性存储。

    Using queue specific variable(s) to efficiently delete expired items in an ordered queue without necessarily checking each queued item's expiry time
    9.
    发明授权
    Using queue specific variable(s) to efficiently delete expired items in an ordered queue without necessarily checking each queued item's expiry time 失效
    使用队列特定变量有效地删除有序队列中的过期项目,而不必检查每个排队的项目的到期时间

    公开(公告)号:US07487272B2

    公开(公告)日:2009-02-03

    申请号:US11281987

    申请日:2005-11-17

    IPC分类号: G06F7/00 G06F7/08

    CPC分类号: G06F7/785 G06F5/06

    摘要: A method for deleting expired items in a queue data structure, the queue data structure comprising a sequential list of ordered data items including a queue head at one end of the sequential list and a queue tail at another end of the sequential list, wherein each data item includes an expiry time, the method comprising: generating a maximum interval value corresponding to a maximum time interval between an expiry time of a first item in the queue and an expiry time of a second item in the queue, wherein the second item is nearer the queue head than the first item; sequentially scanning the list of ordered items from the queue head; responsive to a determination that a scanned item is expired, deleting the scanned item; responsive to a determination that a scanned item will not expire for a time interval greater than the maximum interval value, terminating scanning of the list of ordered items.

    摘要翻译: 一种用于删除队列数据结构中的过期项目的方法,所述队列数据结构包括有序数据项的顺序列表,所述有序数据项包括所述顺序列表的一端的队列头和所述顺序列表的另一端的队列尾,其中每个数据 项目包括到期时间,该方法包括:产生对应于队列中第一项目到期时间与队列中第二项目到期时间之间的最大时间间隔的最大间隔值,其中第二项目更接近 队列头比第一项; 从队列头顺序扫描有序项目列表; 响应于确定扫描的项目已过期,删除所扫描的项目; 响应于确定扫描的项目将不会超过大于最大间隔值的时间间隔,终止对有序项目列表的扫描。