Publish/subscribe messaging system
    1.
    发明授权
    Publish/subscribe messaging system 失效
    发布/订阅消息系统

    公开(公告)号:US07680900B2

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

    申请号:US12108397

    申请日:2008-04-23

    IPC分类号: G06F15/16

    CPC分类号: H04L12/185 H04L12/1859

    摘要: The invention relates to a message broker for managing subscription requests in a multicast messaging system. The messaging system comprises a plurality of publishers publishing information to the broker and a plurality of subscribers subscribing to information received from one or more publishers. The broker is able to receive a subscription request pointing to topic information in which the requesting subscriber is interested, the topic information defining a specific topic within a topic hierarchy. The broker is able to parse the request to determine if the request includes a wildcard and if the request does include a wildcard, the broker instructs the requesting subscriber to listen on a multicast address associated with the topic in the topic hierarchy which precedes the wildcard.

    摘要翻译: 本发明涉及一种用于在多播消息系统中管理订阅请求的消息代理。 消息系统包括向经纪人发布信息的多个发布者以及订阅从一个或多个发布者接收的信息的多个订阅者。 代理能够接收指向请求订阅者感兴趣的主题信息的订阅请求,主题信息定义主题层次结构内的特定主题。 代理能够解析请求以确定请求是否包括通配符,并且如果请求确实包含通配符,则代理指示请求订户在与通配符之前的主题层次结构中的主题相关联的多播地址上进行侦听。

    Publish/Subscribe Messaging System
    2.
    发明申请
    Publish/Subscribe Messaging System 失效
    发布/订阅信息系统

    公开(公告)号:US20080215695A1

    公开(公告)日:2008-09-04

    申请号:US12108397

    申请日:2008-04-23

    IPC分类号: G06F15/16

    CPC分类号: H04L12/185 H04L12/1859

    摘要: The invention relates to a message broker for managing subscription requests in a multicast messaging system. The messaging system comprises a plurality of publishers publishing information to the broker and a plurality of subscribers subscribing to information received from one or more publishers. The broker is able to receive a subscription request pointing to topic information in which the requesting subscriber is interested, the topic information defining a specific topic within a topic hierarchy. The broker is able to parse the request to determine if the request includes a wildcard and if the request does include a wildcard, the broker instructs the requesting subscriber to listen on a multicast address associated with the topic in the topic hierarchy which precedes the wildcard.

    摘要翻译: 本发明涉及一种用于在多播消息系统中管理订阅请求的消息代理。 消息系统包括向经纪人发布信息的多个发布者以及订阅从一个或多个发布者接收的信息的多个订阅者。 代理能够接收指向请求订阅者感兴趣的主题信息的订阅请求,主题信息定义主题层次结构内的特定主题。 代理能够解析请求以确定请求是否包括通配符,并且如果请求确实包含通配符,则代理指示请求订户在与通配符之前的主题层次结构中的主题相关联的多播地址上进行侦听。

    Method of deleting and adding nodes in a spanning tree network by
collating replies from other nodes
    3.
    发明授权
    Method of deleting and adding nodes in a spanning tree network by collating replies from other nodes 失效
    通过整理来自其他节点的回复,在生成树网络中删除和添加节点的方法

    公开(公告)号:US5630184A

    公开(公告)日:1997-05-13

    申请号:US135713

    申请日:1993-10-13

    摘要: A computer forms a node in a network, consisting of computer nodes linked together into a minimum spanning tree topology. When a computer receives a message from a first node linked to it, it forwards the message to other nodes linked to that computer, as well as storing information about the message. As replies are received from the other computers, they are stored and collated together, to allow the computer to send just a single reply message back to the originating node based on the collated replies. This single reply is in turn collated at the next node. The message requests deletion of a particular node from the network. No node deletes the node from the network until replies have been received from all the nodes to which the message was forwarded.

    摘要翻译: 计算机在网络中形成节点,由连接在一起的计算机节点组成最小生成树拓扑。 当计算机从与其链接的第一节点接收到消息时,它将消息转发到链接到该计算机的其他节点,以及存储关于消息的信息。 当从其他计算机接收到答复时,它们被存储并整理在一起,以允许计算机基于整理的回复将仅一个回复消息发送回原始节点。 这个单一答复又在下一个节点上整理。 该消息请求从网络中删除特定节点。 没有节点从网络中删除节点,直到从消息转发到的所有节点接收到回复为止。

    Inbound message rate limit based on maximum queue times
    4.
    发明授权
    Inbound message rate limit based on maximum queue times 有权
    基于最大队列时间的入站消息速率限制

    公开(公告)号:US08589605B2

    公开(公告)日:2013-11-19

    申请号:US12134366

    申请日:2008-06-06

    IPC分类号: G06F5/14

    CPC分类号: H04L47/564

    摘要: 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.

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

    Scoping an alias to a subset of queue partitions
    5.
    发明授权
    Scoping an alias to a subset of queue partitions 有权
    将别名范围划分为队列分区的子集

    公开(公告)号:US08561084B2

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

    申请号:US12199059

    申请日:2008-08-27

    IPC分类号: G06F3/00

    CPC分类号: G06F9/546

    摘要: A method of performing message operations includes receiving a message operation request identifying a queue, retrieving a list of the subset of partitions associated with the alias received in the request, and selecting at least one of the partitions within the retrieved subset. According to the method, the queue includes a plurality of partitions, the request identifies the queue with an alias, and the alias having a subset of the plurality of partitions associated therewith.

    摘要翻译: 执行消息操作的方法包括接收标识队列的消息操作请求,检索与在请求中接收到的别名相关联的分区的子集的列表,以及选择所检索的子集中的至少一个分区。 根据该方法,队列包括多个分区,所述请求使用别名识别队列,并且所述别名具有与其相关联的多个分区的子集。

    QUEUE MANAGEMENT BASED ON MESSAGE AGE
    6.
    发明申请
    QUEUE MANAGEMENT BASED ON MESSAGE AGE 审中-公开
    基于消息年龄的队伍管理

    公开(公告)号:US20100008377A1

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

    申请号:US12169319

    申请日:2008-07-08

    IPC分类号: H04L12/28

    摘要: 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 and discard at least one message when an age of the message exceeds an expiration time.

    摘要翻译: 用于管理服务器组合中的入站消息的系统,包括一个或多个消息消费者。 该系统包括被配置为从第一外围设备接收入站消息并将消息发送到多个消息消费者中的一个或多个的服务器。 系统还包括耦合到服务器的入站消息队列,入站消息队列被配置为存储入站消息,并且当消息的年龄超过到期时间时丢弃至少一个消息。

    METHOD AND SYSTEM FOR PREFERENTIAL REPLY ROUTING
    7.
    发明申请
    METHOD AND SYSTEM FOR PREFERENTIAL REPLY ROUTING 审中-公开
    优先回复路由的方法和系统

    公开(公告)号:US20090313637A1

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

    申请号:US12138585

    申请日:2008-06-13

    IPC分类号: G06F9/54

    CPC分类号: G06F9/546 G06F2209/548

    摘要: A method for preferential reply routing, the method includes: receiving a request-reply message from a requesting application; detecting there is a preferred partition of a reply queue managed locally to an application server to which the requesting application is connected; qualifying a name of a reply queue stored in the request-reply message so that the name refers to the local partition that is managed locally to the application server; determining whether the local partition is available; wherein in the event the local partition is available: storing a reply message in the local partition; and retrieving the reply message from the local partition in response to the requesting application.

    摘要翻译: 一种用于优先回复路由的方法,所述方法包括:从请求应用接收请求应答消息; 检测到本地管理的应答队列的优选分区到请求应用连接到的应用服务器; 限定存储在请求 - 回复消息中的回复队列的名称,以便该名称引用本地管理到应用服务器的本地分区; 确定本地分区是否可用; 其中在本地分区可用的情况下:在本地分区中存储回复消息; 以及响应于所述请求应用从所述本地分区检索所述应答消息。

    SCOPING AN ALIAS TO A SUBSET OF QUEUE PARTITIONS
    8.
    发明申请
    SCOPING AN ALIAS TO A SUBSET OF QUEUE PARTITIONS 有权
    将其描述为一系列队列分区

    公开(公告)号:US20100058357A1

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

    申请号:US12199059

    申请日:2008-08-27

    IPC分类号: G06F9/54

    CPC分类号: G06F9/546

    摘要: A method of performing message operations includes receiving a message operation request identifying a queue, retrieving a list of the subset of partitions associated with the alias received in the request, and selecting at least one of the partitions within the retrieved subset. According to the method, the queue includes a plurality of partitions, the request identifies the queue with an alias, and the alias having a subset of the plurality of partitions associated therewith.

    摘要翻译: 执行消息操作的方法包括接收标识队列的消息操作请求,检索与在请求中接收到的别名相关联的分区的子集的列表,以及选择所检索的子集中的至少一个分区。 根据该方法,队列包括多个分区,所述请求使用别名识别队列,并且所述别名具有与其相关联的多个分区的子集。

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

    公开(公告)号:US20090307393A1

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

    申请号:US12134366

    申请日:2008-06-06

    IPC分类号: G06F5/14

    CPC分类号: H04L47/564

    摘要: 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.

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

    Computer workstation
    10.
    发明授权
    Computer workstation 失效
    电脑工作站

    公开(公告)号:US5454079A

    公开(公告)日:1995-09-26

    申请号:US127935

    申请日:1993-09-28

    CPC分类号: H04L29/06 H04L69/04

    摘要: A computer workstation runs an application 12 which generates data for transmission over a network. The workstation includes a communications subsystem 14 which is responsible for actually sending data generated by the application onto the network. The application therefore passes data 22 for sending to the communications subsystem, along with the identification 24 of the channel over which that data is to be sent, and compression information 26. In a first embodiment the communications subsystem contains a variety of compression routines 40, and the compression information indicates which of these routines is most appropriate for the data in question. In a second embodiment, the compression information is a call-back function 92, whereby the communications subsystem can call back to the application program to perform the compression itself.

    摘要翻译: 计算机工作站运行应用程序12,该应用程序生成用于通过网络传输的数据。 工作站包括通信子系统14,其负责将应用产生的数据实际发送到网络上。 因此,应用程序将用于发送到通信子系统的数据22以及要发送该数据的信道的标识24以及压缩信息26.在第一实施例中,通信子系统包含各种压缩例程40, 并且压缩信息指示这些例程中的哪一个最适合于所讨论的数据。 在第二实施例中,压缩信息是回叫函数92,由此通信子系统可以回调应用程序以执行本身的压缩。