Systems and methods for storing and transferring message data
First Claim
1. A method, comprising:
- performing by one or more computer processors;
storing a plurality of blocks in a queue,wherein each block includes one or more respective messages received from at least one publisher,wherein each block is associated with a time that the block was stored in the queue, andwherein storage times increase from a block designating a head of the queue to a block designating a tail of the queue;
designating as inactive one or more blocks having associated storage times that are older than a first time;
allowing messages to be read from inactive blocks until a second time that is older than the first time; and
deleting one or more inactive blocks from the queue having associated storage times that are older than the second time.
6 Assignments
0 Petitions
Accused Products
Abstract
Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for storing and transferring messages. An example method includes storing a plurality of blocks in a queue, wherein each block includes one or more respective messages received from at least one publisher, wherein each block is associated with a time that the block was stored in the queue, and wherein storage times increase from a block designating a head of the queue to a block designating a tail of the queue. The example method also includes designating as inactive one or more blocks having associated storage times that are older than a first time, allowing messages to be read from inactive blocks until a second time that is older than the first time, and deleting one or more inactive blocks from the queue having associated storage times that are older than the second time.
-
Citations
20 Claims
-
1. A method, comprising:
performing by one or more computer processors; storing a plurality of blocks in a queue, wherein each block includes one or more respective messages received from at least one publisher, wherein each block is associated with a time that the block was stored in the queue, and wherein storage times increase from a block designating a head of the queue to a block designating a tail of the queue; designating as inactive one or more blocks having associated storage times that are older than a first time; allowing messages to be read from inactive blocks until a second time that is older than the first time; and deleting one or more inactive blocks from the queue having associated storage times that are older than the second time. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
11. A system, comprising:
one or more computer processors programmed to perform operations to; store a plurality of blocks in a queue, wherein each block includes one or more respective messages received from at least one publisher, wherein each block is associated with a time that the block was stored in the queue, and wherein storage times increase from a block designating a head of the queue to a block designating a tail of the queue; designate as inactive one or more blocks having associated storage times that are older than a first time; allow messages to be read from inactive blocks until a second time that is older than the first time; and delete one or more inactive blocks from the queue having associated storage times that are older than the second time. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19)
-
20. A non-transitory computer-readable medium having instructions stored thereon that, when executed by one or more computer processors, cause the one or more computer processors to:
-
store a plurality of blocks in a queue, wherein each block includes one or more respective messages received from at least one publisher, wherein each block is associated with a time that the block was stored in the queue, and wherein storage times increase from a block designating a head of the queue to a block designating a tail of the queue; designate as inactive one or more blocks having associated storage times that are older than a first time; allow messages to be read from inactive blocks until a second time that is older than the first time; and delete one or more inactive blocks from the queue having associated storage times that are older than the second time.
-
Specification