公开(公告)号：US07996849B2

公开(公告)日：2011-08-09

申请号：US12022170

申请日：2008-01-30

申请人： Anthony Alan Garrard ,  David John Locke

发明人： Anthony Alan Garrard ,  David John Locke

IPC分类号： G06F13/00

CPC分类号： H04L47/2458 ,  H04L47/10 ,  H04L47/245 ,  H04L47/50

摘要： Provided are a method, apparatus and a computer program for managing message queues. Message streaming is enabled in a transactional messaging system that supports priority ordering of messages, without the need for complex locking mechanisms. Any messages which are transferred from a message queue to a message consumer after the message consumer initiates commit processing are replaced on the message queue at an appropriate position ahead of other messages. As part of commit processing, the consumer sends back to the manager of the message queue an identification of messages delivered to it before the commit, and this list of messages is extracted and compared with a message log to identify undelivered messages. Successfully delivered and committed messages can be committed by the queue manager, and undelivered messages can be replaced on the queue. A special high priority is assigned to the replaced messages to place them ahead of other messages.

摘要翻译： 提供了一种用于管理消息队列的方法，装置和计算机程序。 消息流在支持消息优先级排序的事务消息系统中启用，而不需要复杂的锁定机制。 在消息使用方启动提交处理之后从消息队列传送到消息使用者的任何消息在消息队列之前在其他消息之前的适当位置被替换。 作为提交处理的一部分，消费者在提交之前向消息队列的管理者发送传递给它的消息的标识，并且提取该消息列表并将其与消息日志进行比较以识别未传递的消息。 队列管理器可以提交成功传递和提交的消息，并且可以在队列中替换未传递的消息。 将特别的高优先级分配给替换的消息，以将它们置于其他消息之前。

公开(公告)号：US20080196039A1

公开(公告)日：2008-08-14

申请号：US12022170

申请日：2008-01-30

申请人： Anthony Alan Garrard ,  David John Locke

发明人： Anthony Alan Garrard ,  David John Locke

IPC分类号： G06F3/00

CPC分类号： H04L47/2458 ,  H04L47/10 ,  H04L47/245 ,  H04L47/50

摘要： Provided are a method, apparatus and a computer program for managing message queues. Message streaming is enabled in a transactional messaging system that supports priority ordering of messages, without the need for complex locking mechanisms. Any messages which are transferred from a message queue to a message consumer after the message consumer initiates commit processing are replaced on the message queue at an appropriate position ahead of other messages. As part of commit processing, the consumer sends back to the manager of the message queue an identification of messages delivered to it before the commit, and this list of messages is extracted and compared with a message log to identify undelivered messages. Successfully delivered and committed messages can be committed by the queue manager, and undelivered messages can be replaced on the queue. A special high priority is assigned to the replaced messages to place them ahead of other messages.

摘要翻译： 提供了一种用于管理消息队列的方法，装置和计算机程序。 消息流在支持消息优先级排序的事务消息系统中启用，而不需要复杂的锁定机制。 在消息使用方启动提交处理之后从消息队列传送到消息使用者的任何消息在消息队列之前在其他消息之前的适当位置被替换。 作为提交处理的一部分，消费者在提交之前向消息队列的管理者发送传递给它的消息的标识，并且提取该消息列表并将其与消息日志进行比较以识别未传递的消息。 队列管理器可以提交成功传递和提交的消息，并且可以在队列中替换未传递的消息。 将特别的高优先级分配给替换的消息，以将它们置于其他消息之前。