会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 3. 发明授权
    • Locked receive locations
    • 锁定接收位置
    • US08010608B2
    • 2011-08-30
    • US11146714
    • 2005-06-07
    • Kartik ParamasivamSanjib SahaJean-Emile Elien
    • Kartik ParamasivamSanjib SahaJean-Emile Elien
    • G06F15/16G06F15/173
    • G06F9/546H04L69/40
    • The subject invention provides a system and/or a method that facilitates enhancing an adapter utilizing a locking mechanism between a receive location and a process. An interface component can receive a message related to a receive location that is an endpoint. A lock component binds the receive location to the process such that the process exclusively receives the messages from the endpoint at a single instance in real time. Moreover, the lock component can provide a replacement/switching technique, wherein a process that participates in a locking relationship can be switched with another process based at least in part upon the health of the process.
    • 本发明提供一种有助于利用接收位置和过程之间的锁定机构来增强适配器的系统和/或方法。 接口组件可以接收与作为端点的接收位置相关的消息。 锁定组件将接收位置绑定到进程,使得该进程实时地在单个实例处从端点单独接收消息。 此外,锁定部件可以提供替换/切换技术,其中参与锁定关系的过程可以至少部分地基于过程的健康而与另一进程切换。
    • 5. 发明申请
    • Providing flow control and moderation in a distributed message processing system
    • 在分布式消息处理系统中提供流量控制和审核
    • US20060277317A1
    • 2006-12-07
    • US11144412
    • 2005-06-03
    • Wayne ClarkLee GraberKartik ParamasivamSiddhartha RoySanjib SahaSumitra Sujanani
    • Wayne ClarkLee GraberKartik ParamasivamSiddhartha RoySanjib SahaSumitra Sujanani
    • G06F15/16
    • H04L47/22G06Q10/06H04L47/10H04L47/25
    • Systems and methods for controlling the work load on a distributed system comprising a plurality of stages are provided. The capacity of a present stage is monitored, using either various resources of the present stage or rates of work completion and work receipt of the present stage. Information indicating the capacity of a succeeding stage are obtained and communicated to the present stage. The monitored capacity information of the present stage and the communicated information of the succeeding stage, either alone or in combination, are used to determine if a throttling action is necessary to control the load of work at the present stage. A provided throttling technique inserts an appropriate delay before the present stage to allow the present stage to process an amount of work without saturating the capacity of the present stage. This technique is applied at each stage of the distributed system to control the work load of the overall system by controlling the work load at each stage.
    • 提供了用于控制包括多个级的分布式系统上的工作负载的系统和方法。 使用现阶段的各种资源或工作完成率和现阶段工作收到情况监测现阶段的能力。 获得指示后续能力的信息并传达到现阶段。 目前阶段的监控能力信息和后续阶段的通信信息单独或组合用于确定是否需要节流动作来控制现阶段的工作负荷。 提供的节流技术在当前阶段之前插入适当的延迟,以允许当前阶段处理一定量的工作而不使本阶段的容量饱和。 该技术应用于分布式系统的各个阶段,通过控制各阶段的工作负荷来控制整个系统的工作负荷。
    • 6. 发明授权
    • Automatic recovery from failures of messages within a data interchange
    • 从数据交换中的消息故障自动恢复
    • US07954112B2
    • 2011-05-31
    • US11133548
    • 2005-05-20
    • Ruslan A. YakushevKartik ParamasivamDavid Kent DowningJean-Emile ElienWei-Lun Lo
    • Ruslan A. YakushevKartik ParamasivamDavid Kent DowningJean-Emile ElienWei-Lun Lo
    • G06F3/00G06F9/44G06F9/46G06F13/00
    • G06Q10/107G06F9/546H04L51/30H04L69/40
    • Data interchanges are processed so that problematic individual elements within the data interchanges do not cause the processing of the data interchanges to be suspended unless there is a catastrophic error. The data interchanges are split up by flat file and/or XML disassemblers of a message engine into independent messages even if some elements are incorrect or cause processing failures. Those messages in the interchange that may be processed are processed, while those that would cause processing errors are suspended in a suspend queue for recovery processing. Even when a message is placed in the suspend queue, processing continues with the next independent message in the data interchange. Messages that are placed in the suspend queue for lack of routing information may be resumed by providing the routing information and again attempting to route the previously suspended message. The method of the invention is scalable since it works regardless of the size of the interchange or its individual message elements.
    • 处理数据交换,使得数据交换内的有问题的单个元素不会导致数据交换的处理被暂停,除非存在灾难性错误。 数据交换由消息引擎的平面文件和/或XML反汇编器分离成独立的消息,即使某些元素不正确或导致处理失败。 处理可能被处理的交换中的那些消息,而导致处理错误的那些消息被挂起在用于恢复处理的挂起队列中。 即使当一个消息被放置在挂起队列中时,数据交换中的下一个独立消息继续处理。 由于缺少路由信息而放置在挂起队列中的消息可以通过提供路由信息并再次尝试路由先前暂停的消息来恢复。 本发明的方法是可扩展的,因为它可以工作,而不管交换机或其各个消息元素的大小。
    • 7. 发明申请
    • Automatic recovery from failures of messages within a data interchange
    • 从数据交换中的消息故障自动恢复
    • US20060265455A1
    • 2006-11-23
    • US11133548
    • 2005-05-20
    • Ruslan YakushevKartik ParamasivamDavid DowningJean-Emile ElienWei-Lun Lo
    • Ruslan YakushevKartik ParamasivamDavid DowningJean-Emile ElienWei-Lun Lo
    • G06F15/16
    • G06Q10/107G06F9/546H04L51/30H04L69/40
    • Data interchanges are processed so that problematic individual elements within the data interchanges do not cause the processing of the data interchanges to be suspended unless there is a catastrophic error. The data interchanges are split up by flat file and/or XML disassemblers of a message engine into independent messages even if some elements are incorrect or cause processing failures. Those messages in the interchange that may be processed are processed, while those that would cause processing errors are suspended in a suspend queue for recovery processing. Even when a message is placed in the suspend queue, processing continues with the next independent message in the data interchange. Messages that are placed in the suspend queue for lack of routing information may be resumed by providing the routing information and again attempting to route the previously suspended message. The method of the invention is scalable since it works regardless of the size of the interchange or its individual message elements.
    • 处理数据交换,使得数据交换内的有问题的单个元素不会导致数据交换的处理被暂停,除非存在灾难性错误。 数据交换由消息引擎的平面文件和/或XML反汇编器分离成独立的消息,即使某些元素不正确或导致处理失败。 处理可能被处理的交换中的那些消息,而导致处理错误的那些消息被挂起在用于恢复处理的挂起队列中。 即使当一个消息被放置在挂起队列中时,数据交换中的下一个独立消息继续处理。 由于缺少路由信息而放置在挂起队列中的消息可以通过提供路由信息并再次尝试路由先前暂停的消息来恢复。 本发明的方法是可扩展的,因为它可以工作,而不管交换机或其各个消息元素的大小。
    • 9. 发明授权
    • Providing flow control and moderation in a distributed message processing system
    • 在分布式消息处理系统中提供流量控制和审核
    • US08150994B2
    • 2012-04-03
    • US11144412
    • 2005-06-03
    • Wayne A. ClarkLee B. GraberKartik ParamasivamSiddhartha RoySanjib SahaSumitra Sujanani
    • Wayne A. ClarkLee B. GraberKartik ParamasivamSiddhartha RoySanjib SahaSumitra Sujanani
    • G06F15/16
    • H04L47/22G06Q10/06H04L47/10H04L47/25
    • Systems and methods for controlling the work load on a distributed system comprising a plurality of stages are provided. The capacity of a present stage is monitored, using either various resources of the present stage or rates of work completion and work receipt of the present stage. Information indicating the capacity of a succeeding stage are obtained and communicated to the present stage. The monitored capacity information of the present stage and the communicated information of the succeeding stage, either alone or in combination, are used to determine if a throttling action is necessary to control the load of work at the present stage. A provided throttling technique inserts an appropriate delay before the present stage to allow the present stage to process an amount of work without saturating the capacity of the present stage. This technique is applied at each stage of the distributed system to control the work load of the overall system by controlling the work load at each stage.
    • 提供了用于控制包括多个级的分布式系统上的工作负载的系统和方法。 使用现阶段的各种资源或工作完成率和现阶段工作收到情况监测现阶段的能力。 获得指示后续能力的信息并传达到现阶段。 目前阶段的监控能力信息和后续阶段的通信信息单独或组合用于确定是否需要节流动作来控制现阶段的工作负荷。 提供的节流技术在当前阶段之前插入适当的延迟,以允许当前阶段处理一定量的工作而不使本阶段的容量饱和。 该技术应用于分布式系统的各个阶段,通过控制各阶段的工作负荷来控制整个系统的工作负荷。
    • 10. 发明申请
    • SCHEDULED MESSAGES IN A SCALABLE MESSAGING SYSTEM
    • 可扩展消息传递系统中的调度消息
    • US20130304826A1
    • 2013-11-14
    • US13470928
    • 2012-05-14
    • Bin LiKartik ParamasivamManu SrivastavaSeongJoon KwakVenkata Raja Gopal Ravipati
    • Bin LiKartik ParamasivamManu SrivastavaSeongJoon KwakVenkata Raja Gopal Ravipati
    • G06F15/16
    • H04L51/14
    • Techniques are provided for scheduled and non-scheduled delivery of messages. A message directed to at least one consumer is received at a message entity. The message is determined to include a scheduled delivery time. The received message is stored in a scheduled sub-queue of the message entity. Activation metadata is retrieved and stored for any messages stored in the scheduled sub-queue that include a scheduled delivery time within a predetermined upcoming time period. If when the message is received, the scheduled delivery time of the message is within a current activation window, the activation metadata for the message may be extracted and stored immediately. The stored activation metadata is analyzed to determine a batch of messages in the scheduled sub-queue ready for delivery. The determined batch of messages is stored in an active sub-queue of the message entity, to be ready for delivery at the request of a consumer.
    • 提供技术用于定期和非定期传递消息。 在消息实体处接收指向至少一个消费者的消息。 消息被确定为包括预定的交货时间。 接收到的消息被存储在消息实体的调度子队列中。 为预定的子队列中存储的任何消息检索和存储激活元数据,所述消息在预定的即将到来的时间段内包括预定的递送时间。 如果当接收到消息时,消息的预定传送时间在当前激活窗口内,则可以立即提取并存储消息的激活元数据。 分析存储的激活元数据以确定准备传送的计划子队列中的一批消息。 确定的消息批次存储在消息实体的活动子队列中,以便在消费者的请求下准备好传送。