专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明授权

US09015303B2 Message queue behavior optimizations 有权
标题翻译：消息队列行为优化
公开(公告)号：US09015303B2
公开(公告)日：2015-04-21
申请号：US13230823
申请日：2011-09-12
申请人： Jayteerth Katti , Kartik Paramasivam , Stuart John Langley , Pramod Gurunath , Muralidhar Krishnaprasad , Elvin Morales , Manu Srivastava
发明人： Jayteerth Katti , Kartik Paramasivam , Stuart John Langley , Pramod Gurunath , Muralidhar Krishnaprasad , Elvin Morales , Manu Srivastava
IPC分类号： G06F15/173 , H04L12/58
CPC分类号： H04L51/26 , H04L51/30
摘要： Network and storage calls are reduced by batching messages. Messages are collected from a client and sent to the gateway or backend application in one round trip. Alternatively, the messages are collected for different entities, and the batched messages are durably stored. Related messages, which may have the same sessionID, are grouped into a logical unit or session. This session may be locked to a single message consumer. A session may be associated with an application processing state as an atomic unit of work while other operations are performed on the messages in the session. Acknowledgements are accumulated by a broker on a message server, but the messages are not immediately deleted. Instead, multiple messages in a selected range are periodically truncated from a message store in a single operation. Expired messages for active sessions are proactive cleaned up to prevent sessions from reaching a quota or limit.
摘要翻译：通过批量消息来减少网络和存储呼叫。消息从客户端收集，并一次性发送到网关或后端应用程序。或者，为不同的实体收集消息，并且批量消息被持久地存储。可能具有相同sessionID的相关消息被分组为逻辑单元或会话。此会话可能被锁定到单个消息消费者。会话可以与作为原子工作单元的应用处理状态相关联，而对会话中的消息执行其他操作。致谢由消息服务器上的代理商累积，但消息不会立即被删除。相反，在单个操作中，从消息存储区定期地截断所选范围内的多个消息。活跃会话的过期消息被主动清理，以防止会话达到配额或限制。

2. 发明申请

US20130066977A1 MESSAGE QUEUE BEHAVIOR OPTIMIZATIONS 有权
标题翻译：消息队列行为优化
公开(公告)号：US20130066977A1
公开(公告)日：2013-03-14
申请号：US13230823
申请日：2011-09-12
申请人： Jayteerth Katti , Kartik Paramasivam , Stuart John Langley , Pramod Gurunath , Muralidhar Krishnaprasad , Elvin Morales , Manu Srivastava
发明人： Jayteerth Katti , Kartik Paramasivam , Stuart John Langley , Pramod Gurunath , Muralidhar Krishnaprasad , Elvin Morales , Manu Srivastava
IPC分类号： G06F15/16
CPC分类号： H04L51/26 , H04L51/30
摘要： Network and storage calls are reduced by batching messages. Messages are collected from a client and sent to the gateway or backend application in one round trip. Alternatively, the messages are collected for different entities, and the batched messages are durably stored. Related messages, which may have the same sessionID, are grouped into a logical unit or session. This session may be locked to a single message consumer. A session may be associated with an application processing state as an atomic unit of work while other operations are performed on the messages in the session. Acknowledgements are accumulated by a broker on a message server, but the messages are not immediately deleted. Instead, multiple messages in a selected range are periodically truncated from a message store in a single operation. Expired messages for active sessions are proactive cleaned up to prevent sessions from reaching a quota or limit.
摘要翻译：通过批量消息来减少网络和存储呼叫。消息从客户端收集，并一次性发送到网关或后端应用程序。或者，为不同的实体收集消息，并且批量消息被持久地存储。可能具有相同sessionID的相关消息被分组为逻辑单元或会话。此会话可能被锁定到单个消息消费者。会话可以与作为原子工作单元的应用处理状态相关联，而对会话中的消息执行其他操作。致谢由消息服务器上的代理商累积，但消息不会立即被删除。相反，在单个操作中，从消息存储区定期地截断所选范围内的多个消息。活跃会话的过期消息被主动清理，以防止会话达到配额或限制。

3. 发明授权

US09344391B2 High density hosting for messaging service 有权
标题翻译：高密度主机用于消息传递服务
公开(公告)号：US09344391B2
公开(公告)日：2016-05-17
申请号：US13419435
申请日：2012-03-14
申请人： Kartik Paramasivam , Sung Hwa Jin , Manu Srivastava , Muralidhar Krishnaprasad , Ruppert Rolf Koch , Venkata Raja Gopal Ravipati , Bin Li
发明人： Kartik Paramasivam , Sung Hwa Jin , Manu Srivastava , Muralidhar Krishnaprasad , Ruppert Rolf Koch , Venkata Raja Gopal Ravipati , Bin Li
IPC分类号： H04L12/58 , H04L29/08 , G06F9/50 , G06F9/54
CPC分类号： H04L67/1097 , G06F9/5088 , G06F9/546 , G06F2209/5022 , G06F2209/548 , H04L51/14 , H04L51/34 , H04L67/06 , H04L67/1002 , H04L67/148
摘要： Aspects of the subject matter described herein relate migrating message for a messaging service. In aspects, a determination is made that messages need to be migrated based on a threshold being crossed. In response, an agent is instructed to migrate data associated with the messages to another location. The agent uses various factors to determine one or more queues to migrate. While a queue is being migrated, during a first portion of the migration, messages may be added to and removed from the queue as senders send new messages and receivers consume messages. During a second portion of the migration, the queue is frozen to disallow the queue to be used for receiving new messages and delivering queued messages. The migration may be orchestrated to attempt to achieve certain goals.
摘要翻译：本文描述的主题的方面涉及消息传递服务的迁移消息。在方面，确定消息需要基于正在被越过的阈值来迁移。作为响应，指示代理将与消息相关联的数据迁移到另一位置。代理使用各种因素来确定要迁移的一个或多个队列。当迁移队列时，在迁移的第一部分期间，当发送者发送新消息并且接收者消费消息时，消息可以被添加到队列中并从队列中移除。在迁移的第二部分期间，队列被冻结以不允许该队列用于接收新消息并传送排队的消息。迁移可能被编排以试图实现某些目标。

4. 发明申请

US20130246561A1 HIGH DENSITY HOSTING FOR MESSAGING SERVICE 有权
标题翻译：高密度传送消息服务
公开(公告)号：US20130246561A1
公开(公告)日：2013-09-19
申请号：US13419435
申请日：2012-03-14
申请人： Kartik Paramasivam , Sung Hwa Jin , Manu Srivastava , Muralidhar Krishnaprasad , Ruppert Rolf Koch , Venkata Raja Gopal Ravipati , Bin Li
发明人： Kartik Paramasivam , Sung Hwa Jin , Manu Srivastava , Muralidhar Krishnaprasad , Ruppert Rolf Koch , Venkata Raja Gopal Ravipati , Bin Li
IPC分类号： G06F15/16
CPC分类号： H04L67/1097 , G06F9/5088 , G06F9/546 , G06F2209/5022 , G06F2209/548 , H04L51/14 , H04L51/34 , H04L67/06 , H04L67/1002 , H04L67/148
摘要： Aspects of the subject matter described herein relate migrating message for a messaging service. In aspects, a determination is made that messages need to be migrated based on a threshold being crossed. In response, an agent is instructed to migrate data associated with the messages to another location. The agent uses various factors to determine one or more queues to migrate. While a queue is being migrated, during a first portion of the migration, messages may be added to and removed from the queue as senders send new messages and receivers consume messages. During a second portion of the migration, the queue is frozen to disallow the queue to be used for receiving new messages and delivering queued messages. The migration may be orchestrated to attempt to achieve certain goals.
摘要翻译：本文描述的主题的方面涉及消息传递服务的迁移消息。在方面，确定消息需要基于正在被越过的阈值来迁移。作为响应，指示代理将与消息相关联的数据迁移到另一位置。代理使用各种因素来确定要迁移的一个或多个队列。当迁移队列时，在迁移的第一部分期间，当发送者发送新消息并且接收者消费消息时，消息可以被添加到队列中并从队列中移除。在迁移的第二部分期间，队列被冻结以不允许队列用于接收新消息并传送排队的消息。迁移可能被编排以试图达到某些目标。

5. 发明授权

US08903925B2 Scheduled messages in a scalable messaging system 有权
标题翻译：可扩展消息系统中的计划消息
公开(公告)号：US08903925B2
公开(公告)日：2014-12-02
申请号：US13470928
申请日：2012-05-14
申请人： Bin Li , Kartik Paramasivam , Manu Srivastava , SeongJoon Kwak , Venkata Raja Gopal Ravipati
发明人： Bin Li , Kartik Paramasivam , Manu Srivastava , SeongJoon Kwak , Venkata Raja Gopal Ravipati
IPC分类号： G06F15/16 , H04L12/56
CPC分类号： 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.
摘要翻译：提供技术用于定期和非定期传递消息。在消息实体处接收指向至少一个消费者的消息。消息被确定为包括预定的交货时间。接收到的消息被存储在消息实体的调度子队列中。为预定的子队列中存储的任何消息检索和存储激活元数据，所述消息在预定的即将到来的时间段内包括预定的递送时间。如果当接收到消息时，消息的预定传送时间在当前激活窗口内，则可以立即提取并存储消息的激活元数据。分析存储的激活元数据以确定准备传送的计划子队列中的一批消息。确定的消息批次存储在消息实体的活动子队列中，以便在消费者的请求下准备好传送。

6. 发明申请

US20130304826A1 SCHEDULED MESSAGES IN A SCALABLE MESSAGING SYSTEM 有权
标题翻译：可扩展消息传递系统中的调度消息
公开(公告)号：US20130304826A1
公开(公告)日：2013-11-14
申请号：US13470928
申请日：2012-05-14
申请人： Bin Li , Kartik Paramasivam , Manu Srivastava , SeongJoon Kwak , Venkata Raja Gopal Ravipati
发明人： Bin Li , Kartik Paramasivam , Manu Srivastava , SeongJoon Kwak , Venkata Raja Gopal Ravipati
IPC分类号： G06F15/16
CPC分类号： 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.
摘要翻译：提供技术用于定期和非定期传递消息。在消息实体处接收指向至少一个消费者的消息。消息被确定为包括预定的交货时间。接收到的消息被存储在消息实体的调度子队列中。为预定的子队列中存储的任何消息检索和存储激活元数据，所述消息在预定的即将到来的时间段内包括预定的递送时间。如果当接收到消息时，消息的预定传送时间在当前激活窗口内，则可以立即提取并存储消息的激活元数据。分析存储的激活元数据以确定准备传送的计划子队列中的一批消息。确定的消息批次存储在消息实体的活动子队列中，以便在消费者的请求下准备好传送。

7. 发明申请

US20130204934A1 EFFICIENTLY RECEIVING MESSAGES ACROSS A LARGE NUMBER OF MESSAGING ENTITIES 有权
标题翻译：有效地接收大量消息传递实体的信息
公开(公告)号：US20130204934A1
公开(公告)日：2013-08-08
申请号：US13368107
申请日：2012-02-07
申请人： Manu Srivastava , Kartik Paramasivam , Murali Krishnaprasad
发明人： Manu Srivastava , Kartik Paramasivam , Murali Krishnaprasad
IPC分类号： G06F15/16
CPC分类号： G06F9/542 , G06F2209/544
摘要： A messaging service is described that facilitates the efficient receipt of messages by a client from across a large number of messaging entities hosted by different messaging hosts within a distributed messaging system. A gateway in the distributed messaging system forwards a request for an available message or set of related messages from the client to each of the messaging hosts. Each messaging host provides a response to a request if a messaging entity hosted thereby includes at least one available message or set of related messages. The messaging host manages the order in which responses from different messaging entities are provided to ensure fairness. The gateway forwards a selected one of the responses to the consumer, while caching the other responses to service future requests from the consumer.
摘要翻译：描述了消息传递服务，其有助于客户端跨越分布式消息系统内的不同消息传递主机托管的大量消息传送实体的有效接收消息。分布式消息系统中的网关向客户端向每个消息收发主机转发可用消息或一组相关消息的请求。如果由其托管的消息传送实体包括至少一个可用消息或一组相关消息，则每个消息主机提供对请求的响应。消息接发主机管理提供来自不同消息传递实体的响应以确保公平性的顺序。网关将所选择的一个响应转发给消费者，同时将其他响应缓存到来自消费者的将来的未来请求。

8. 发明授权

US10002033B2 Efficiently receiving messages across a large number of messaging entities 有权
公开(公告)号：US10002033B2
公开(公告)日：2018-06-19
申请号：US13368107
申请日：2012-02-07
申请人： Manu Srivastava , Kartik Paramasivam , Murali Krishnaprasad
发明人： Manu Srivastava , Kartik Paramasivam , Murali Krishnaprasad
IPC分类号： G06F15/16 , G06F9/54
CPC分类号： G06F9/542 , G06F2209/544
摘要： A messaging service is described that facilitates the efficient receipt of messages by a client from across a large number of messaging entities hosted by different messaging hosts within a distributed messaging system. A gateway in the distributed messaging system forwards a request for an available message or set of related messages from the client to each of the messaging hosts. Each messaging host provides a response to a request if a messaging entity hosted thereby includes at least one available message or set of related messages. The messaging host manages the order in which responses from different messaging entities are provided to ensure fairness. The gateway forwards a selected one of the responses to the consumer, while caching the other responses to service future requests from the consumer.

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式