Method of routing messages to multiple consumers
    1.
    发明授权
    Method of routing messages to multiple consumers 失效
    将消息路由到多个消费者的方法

    公开(公告)号:US08180823B2

    公开(公告)日:2012-05-15

    申请号:US12198939

    申请日:2008-08-27

    CPC classification number: G06Q10/00 G06Q30/00

    Abstract: A method of routing messages to multiple consumers comprises determining a probability function defining message classification probabilities for each of a plurality of consumer sets, receiving a plurality of messages, classifying each message, storing each message in a queue, receiving notification of a consumer available to process a message, ascertaining the consumer set to which the available consumer belongs, accessing the probabilities for the ascertained consumer set, selecting a message classification according to the accessed probabilities, and transmitting a message, of the selected classification, to the available consumer.

    Abstract translation: 将消息路由到多个消费者的方法包括确定为多个消费者集合中的每个消费者集合定义消息分类概率的概率函数,接收多个消息,对每个消息进行分类,将每个消息存储在队列中,接收可用于消费者的消费者的通知 处理消息,确定可用消费者所属的消费者集合,访问所确定的消费者集合的概率,根据所访问的概率选择消息分类,以及将所选择的分类的消息发送到可用消费者。

    Method for Attaching to a Partitioned Queue Spread Across a Plurality of Messaging Servers
    2.
    发明申请
    Method for Attaching to a Partitioned Queue Spread Across a Plurality of Messaging Servers 失效
    连接到跨多个消息服务器的分区队列的方法

    公开(公告)号:US20080040396A1

    公开(公告)日:2008-02-14

    申请号:US11744929

    申请日:2007-05-07

    CPC classification number: G06F9/546 G06F2209/548

    Abstract: There is disclosed a method, apparatus and computer program for an application instance to request attachment to a queue partition on a messaging server within a plurality of messaging servers, each messaging server holding at least one queue partition, the set of queue partitions together forming a single queue. An application instance requests attachment to a queue partition, the request requesting exclusivity with regard to other application instances having a common identifier. Responsive to an indicating that the request has been successful, the application instance interacts with the queue partition.

    Abstract translation: 公开了一种用于应用实例的方法,装置和计算机程序,用于请求附接到多个消息收发服务器内的消息收发服务器上的队列分区,每个消息收发服务器保持至少一个队列分区,该组队列分区一起形成 单队列 应用程序实例请求对队列分区的附件,该请求针对具有公共标识符的其他应用程序实例请求排他性。 响应于指示请求已成功,应用程序实例与队列分区进行交互。

    Redistributing messages in a clustered messaging environment
    3.
    发明授权
    Redistributing messages in a clustered messaging environment 失效
    在群集消息传递环境中重新分发消息

    公开(公告)号:US08082307B2

    公开(公告)日:2011-12-20

    申请号:US11829139

    申请日:2007-07-27

    CPC classification number: G06Q40/06 G06F9/546 G06Q10/107

    Abstract: Messages are redistributed in a clustered messaging environment including messaging servers and consuming applications. Each messaging server has a queue partition operable to contain messages. Each consuming application can connect to a messaging server in to consume one or more messages from a queue partition local to that messaging server. A message on a holding queue partition local to a messaging server without at least one consumer interested in consuming that message is said to be marooned. A marooned message is redistributed from the holding queue partition to a messaging server that does have at least one consumer interested in consuming the message. The redistribution involves identifying a group of servers, each of which has one or more consumers interesting in consuming the message, selecting a server from the group and forwarding the message to the selected server.

    Abstract translation: 消息在集群消息传递环境中重新分发,包括消息传递服务器和消费应用程序。 每个消息收发服务器都有一个可用于包含消息的队列分区。 每个消费应用程序可以连接到消息传递服务器,以从消息服务器本地的队列分区中消耗一个或多个消息。 据信,在消息服务器本地的持有队列分区上的消息,而不至少有一个对消费者感兴趣的消费者的消息被称为是错误的。 一个marooned消息从持有队列分区重新分发到至少有一个消费者对消息有兴趣的消息传递服务器。 重新分配涉及识别一组服务器,每个服务器具有一个或多个消费者在消费消息中感兴趣的消费者,从组中选择服务器并将消息转发到所选择的服务器。

    CONNECTING A CLIENT TO ONE OF A PLURALITY OF SERVERS
    4.
    发明申请
    CONNECTING A CLIENT TO ONE OF A PLURALITY OF SERVERS 审中-公开
    将客户连接到多个服务器之一

    公开(公告)号:US20080313349A1

    公开(公告)日:2008-12-18

    申请号:US12128485

    申请日:2008-05-28

    Abstract: In a client/server network, a client may be able to use any of several servers in accomplishing a particular task but may still have preferences as to which server should, if available, be used. If the preferred server is not available, the client will be connected to an alternate server. If a server having a higher preference than the alternate server becomes available, state information associated with the client session with the alternate server is used in order to decide when the client may be switched to the preferred server without compromising work currently being done.

    Abstract translation: 在客户端/服务器网络中,客户端可能能够使用几个服务器中的任何一个来完成特定任务,但是仍然可以具有关于哪个服务器应该被使用的偏好。 如果首选服务器不可用,则客户端将连接到备用服务器。 如果具有比备用服务器更高的优先级的服务器变得可用,则使用与备用服务器的客户端会话相关联的状态信息,以便确定客户端何时可以切换到优选服务器,而不会影响当前正在完成的工作。

    Redistributing Messages in a Clustered Messaging Environment
    5.
    发明申请
    Redistributing Messages in a Clustered Messaging Environment 失效
    在群集消息传递环境中重新分发消息

    公开(公告)号:US20080034051A1

    公开(公告)日:2008-02-07

    申请号:US11829139

    申请日:2007-07-27

    CPC classification number: G06Q40/06 G06F9/546 G06Q10/107

    Abstract: Messages are redistributed in a clustered messaging environment including messaging servers and consuming applications. Each messaging server has a queue partition operable to contain messages. Each consuming application can connect to a messaging server in to consume one or more messages from a queue partition local to that messaging server. A message on a holding queue partition local to a messaging server without at least one consumer interested in consuming that message is said to be marooned. Using either a push model or a pull model, a marooned message is redistributed from the holding queue partition to a queue partition local to a messaging server that does have at least one consumer interested in consuming the message.

    Abstract translation: 消息在集群消息传递环境中重新分发,包括消息传递服务器和消费应用程序。 每个消息收发服务器都有一个可用于包含消息的队列分区。 每个消费应用程序可以连接到消息传递服务器,以从消息服务器本地的队列分区中消耗一个或多个消息。 据信,在消息服务器本地的持有队列分区上的消息,而不至少有一个对消费者感兴趣的消费者的消息被称为是错误的。 使用推模型或拉式模型,从持有队列分区重新分配已存在的消息到消息服务器本地的队列分区,该消息服务器至少有一个消费者对消息感兴趣。

    Method for attaching to a partitioned queue spread across a plurality of messaging servers
    6.
    发明授权
    Method for attaching to a partitioned queue spread across a plurality of messaging servers 失效
    用于附加到跨越多个消息收发服务器的分区队列的方法

    公开(公告)号:US08199668B2

    公开(公告)日:2012-06-12

    申请号:US11744929

    申请日:2007-05-07

    CPC classification number: G06F9/546 G06F2209/548

    Abstract: There is disclosed a method, apparatus and computer program for an application instance to request attachment to a queue partition on a messaging server within a plurality of messaging servers, each messaging server holding at least one queue partition, the set of queue partitions together forming a single queue. An application instance requests attachment to a queue partition, the request requesting exclusivity with regard to other application instances having a common identifier. Responsive to an indicating that the request has been successful, the application instance interacts with the queue partition.

    Abstract translation: 公开了一种用于应用实例的方法,装置和计算机程序,用于请求附接到多个消息收发服务器内的消息收发服务器上的队列分区,每个消息收发服务器保持至少一个队列分区,该组队列分区一起形成 单队列 应用程序实例请求对队列分区的附件,该请求针对具有公共标识符的其他应用程序实例请求排他性。 响应于指示请求已成功,应用程序实例与队列分区进行交互。

    Method of Routing Messages to Multiple Consumers
    7.
    发明申请
    Method of Routing Messages to Multiple Consumers 失效
    将消息路由到多个消费者的方法

    公开(公告)号:US20100057880A1

    公开(公告)日:2010-03-04

    申请号:US12198939

    申请日:2008-08-27

    CPC classification number: G06Q10/00 G06Q30/00

    Abstract: A method of routing messages to multiple consumers comprises determining a probability function defining message classification probabilities for each of a plurality of consumer sets, receiving a plurality of messages, classifying each message, storing each message in a queue, receiving notification of a consumer available to process a message, ascertaining the consumer set to which the available consumer belongs, accessing the probabilities for the ascertained consumer set, selecting a message classification according to the accessed probabilities, and transmitting a message, of the selected classification, to the available consumer.

    Abstract translation: 将消息路由到多个消费者的方法包括确定为多个消费者集合中的每个消费者集合定义消息分类概率的概率函数,接收多个消息,对每个消息进行分类,将每个消息存储在队列中,接收可用于消费者的消费者的通知 处理消息,确定可用消费者所属的消费者集合,访问所确定的消费者集合的概率,根据所访问的概率选择消息分类,以及将所选择的分类的消息发送到可用消费者。

    Controlling access to a destination in a data processing network
    8.
    发明授权
    Controlling access to a destination in a data processing network 有权
    控制访问数据处理网络中的目的地

    公开(公告)号:US08355401B2

    公开(公告)日:2013-01-15

    申请号:US13196199

    申请日:2011-08-02

    CPC classification number: H04L67/14 H04L67/145 H04L69/14 H04L69/40

    Abstract: Access to a device is controlled in a data processing network by receiving a first request from a client to connect to a device where the device is limited to a fixed number of client connections and connecting the client to an available client connection of the device if the fixed number of client connections on the device would not be exceeded by connecting the client. Access is further controlled by testing liveness of a current client connection on the device if the fixed number of client connections on the device would be exceeded by connecting the client and dropping the current client connection if the liveness testing indicates that the current client connection is not live.

    Abstract translation: 通过从客户端接收到连接到设备被限制到固定数量的客户端连接并将客户机连接到设备的可用客户端连接的设备的数据处理网络中来控制对设备的访问,如果 连接客户端不会超过设备上固定数量的客户端连接。 如果活动测试表明当前客户端连接不是,通过连接客户端并删除当前客户端连接来超过设备上的客户端连接的固定数量,则可以通过测试设备上当前客户端连接的活动来进一步控制访问。 生活。

    Mechanism for delivering messages to competing consumers in a point-to-point system
    9.
    发明授权
    Mechanism for delivering messages to competing consumers in a point-to-point system 失效
    在点对点系统中向竞争消费者传递消息的机制

    公开(公告)号:US07525964B2

    公开(公告)日:2009-04-28

    申请号:US10980034

    申请日:2004-11-03

    CPC classification number: H04L67/2814 H04L67/26 H04L67/2842 H04L67/322

    Abstract: A method, system, and computer program for delivering messages and data to competing consumers. One aspect of the invention includes a message delivery system including a destination messaging engine, one or more receiver messaging engines, and a message pool. The destination messaging engine is configured to distribute data from one or more producers. The receiver messaging engines are configured to request data from the destination messaging engine and transmit the data to one or more consumers. The message pool is configured to store data from the producers, with the destination messaging engine arbitrating data in the message pool among the receiver messaging engines.

    Abstract translation: 用于将消息和数据传递给竞争消费者的方法,系统和计算机程序。 本发明的一个方面包括消息传递系统,其包括目的地消息收发引擎,一个或多个接收者消息传递引擎和消息池。 目的地消息传递引擎被配置为从一个或多个生产者分发数据。 接收器消息传递引擎被配置为从目的地消息收发引擎请求数据并将数据发送到一个或多个消费者。 消息池被配置为存储来自生产者的数据,目的地消息收发引擎在接收器消息传递引擎之间对消息池中的数据进行仲裁。

    INBOUND MESSAGE RATE LIMIT BASED ON MAXIMUM QUEUE TIMES
    10.
    发明申请
    INBOUND MESSAGE RATE LIMIT BASED ON MAXIMUM QUEUE TIMES 有权
    基于最大队列时间的接收消息速率限制

    公开(公告)号:US20090307393A1

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

    申请号:US12134366

    申请日:2008-06-06

    CPC classification number: H04L47/564

    Abstract: A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.

    Abstract translation: 用于管理服务器组合中的入站消息的系统,包括一个或多个消息消费者。 该系统包括被配置为从第一外围设备接收入站消息并将消息发送到多个消息消费者中的一个或多个的服务器。 系统还包括耦合到服务器的入站消息队列,入站消息队列被配置为存储入站消息,直到存储在入站消息队列上的任何消息的时间超过预定阈值。

Patent Agency Ranking