Method and program for classifying fragmented messages
    1.
    发明授权
    Method and program for classifying fragmented messages 有权
    分片消息分类的方法和程序

    公开(公告)号:US07912047B2

    公开(公告)日:2011-03-22

    申请号:US11615345

    申请日:2006-12-22

    IPC分类号: H04L12/28

    CPC分类号: G06F9/546 G06F9/465

    摘要: Prioritization of fragmented messages in an ORB is achieved by intercepting the flow of message data within the ORB, marking the current data stream location and issuing sufficient read commands to gather the message header and control area information. Then classification for priority can be performed using the data in the control area to classify the request. The classification information is stored for the message for later use by queuing and prioritization processes and the data stream marker is reset to the original location. When the queuing and prioritization processes are ready to dispatch the message, the message can be sent on to the higher levels of processing within the ORB where the higher levels of message processing code will process the message, totally unaware of the fact that the message has been classified and/or queued or prioritized prior to delivery to the higher level.

    摘要翻译: 通过拦截ORB中的消息数据流来标记当前数据流位置并发出足够的读取命令来收集消息报头和控制区域信息,来实现ORB中分段消息的优先级。 然后可以使用控制区域中的数据来执行优先级分类,以对请求进行分类。 为消息存储分类信息以供稍后通过排队和优先级处理使用,数据流标记被重置到原始位置。 当排队和优先级处理准备好发送消息时,消息可以被发送到ORB中的较高级别的处理,其中较高级别的消息处理代码将处理消息,完全不知道消息具有 在交付给更高级别之前已被分类和/或排队或优先排序。

    METHOD AND PROGRAM FOR CLASSIFYING FRAGMENTED MESSAGES
    2.
    发明申请
    METHOD AND PROGRAM FOR CLASSIFYING FRAGMENTED MESSAGES 有权
    分类消息消息的方法和程序

    公开(公告)号:US20080151936A1

    公开(公告)日:2008-06-26

    申请号:US11615345

    申请日:2006-12-22

    IPC分类号: H04J3/24

    CPC分类号: G06F9/546 G06F9/465

    摘要: Prioritization of fragmented messages in an ORB is achieved by intercepting the flow of message data within the ORB, marking the current data stream location and issuing sufficient read commands to gather the message header and control area information. Then classification for priority can be performed using the data in the control area to classify the request. The classification information is stored for the message for later use by queuing and prioritization processes and the data stream marker is reset to the original location. When the queuing and prioritization processes are ready to dispatch the message, the message can be sent on to the higher levels of processing within the ORB where the higher levels of message processing code will process the message, totally unaware of the fact that the message has been classified and/or queued or prioritized prior to delivery to the higher level.

    摘要翻译: 通过拦截ORB中的消息数据流来标记当前数据流位置并发出足够的读取命令来收集消息报头和控制区域信息,来实现ORB中分段消息的优先级。 然后可以使用控制区域中的数据来执行优先级分类,以对请求进行分类。 为消息存储分类信息以供稍后通过排队和优先级处理使用,数据流标记被重置到原始位置。 当排队和优先级处理准备好发送消息时,消息可以被发送到ORB中的较高级别的处理,其中较高级别的消息处理代码将处理消息,完全不知道消息具有 在交付给更高级别之前已被分类和/或排队或优先排序。

    Dynamic partitioning of messaging system topics
    3.
    发明授权
    Dynamic partitioning of messaging system topics 失效
    消息系统主题的动态分区

    公开(公告)号:US08037153B2

    公开(公告)日:2011-10-11

    申请号:US10026385

    申请日:2001-12-21

    IPC分类号: G06F15/16

    摘要: A dynamic topic partitioning messaging system. The messaging system can include a message server; one or more topics stored in the message server; one or more subtopics associated with at least one of the topics in the message server; and, a dynamic topic partitioning system configured to partition the topics into the subtopics. Notably, the message server can be Java message service (JMS) compliant. In that regard, the message server can reside in a single process address space. For example, the process address space can be a Java virtual machine (JVM).

    摘要翻译: 动态主题分区消息系统。 消息系统可以包括消息服务器; 存储在消息服务器中的一个或多个主题; 与消息服务器中的至少一个主题相关联的一个或多个子主题; 以及配置为将主题分割为子主题的动态主题分区系统。 值得注意的是,消息服务器可以是符合Java消息服务(JMS)的。 在这方面,消息服务器可以驻留在单个进程地址空间中。 例如,进程地址空间可以是Java虚拟机(JVM)。

    Dynamically updating session state affinity
    4.
    发明授权
    Dynamically updating session state affinity 失效
    动态更新会话状态的亲和度

    公开(公告)号:US07543069B2

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

    申请号:US10967533

    申请日:2004-10-18

    IPC分类号: G06F15/16

    摘要: Session state affinity is maintained in a workload balancing system that includes a hypertext transfer protocol (HTTP) routing server and a plurality of application servers. The application servers maintain backup session state information for a first session to a first server of the plurality of application servers at fewer than all of the plurality of application servers, detect the unavailability of the first application server at an application server of the plurality of application servers other than the first application and determine a second server that continues the first session. An identification of the second server and the first session is sent from an application server of the plurality of application servers to a HTTP routing server responsive to detecting the unavailability of the first server. The identification of the second server and the first session is received at the HTTP routing server and communications associated with the first session are routed from the HTTP routing server to the second server responsive to receiving the identification of the second server so that backup session state information maintained at the second server is used to continue the first session from the first server at the second server.

    摘要翻译: 在包括超文本传输​​协议(HTTP)路由服务器和多个应用服务器的工作负载平衡系统中维护会话状态关联。 所述应用服务器将所述第一会话的备份会话状态信息保持在所述多个应用服务器中的所有多个应用服务器上的所述多个应用服务器的第一服务器,在所述多个应用服务器的应用服务器处检测到所述第一应用服务器的不可用性 不同于第一个应用程序的服务器,并确定继续第一个会话的第二个服务器。 响应于检测到第一服务器的不可用性,将第二服务器和第一会话的标识从多个应用服务器的应用服务器发送到HTTP路由服务器。 第二服务器和第一会话的识别在HTTP路由服务器处被接收,并且响应于接收到第二服务器的标识,将与第一会话关联的通信从HTTP路由服务器路由到第二服务器,使得备份会话状态信息 在第二服务器上维护的服务器被用于从第二服务器的第一服务器继续第一会话。