Systems and methods for reorganization of messages in queuing systems

A system of providing reorganization of messages in queuing systems, comprising:

• a) at least one processor;
• b) at least one input device;
• and
• c) at least one storage device storing processor-executable instructions which, when executed by the at least one processor, perform a method including:
• receiving a statement to reorganize one or more messages within a first ordered data structure;
• translating the statement into a first set of instructions for identifying one or more messages on which to perform one or more operations, a second set of instructions for performing the one or more operations on the identified one or more messages, and a third set of instructions for storing, in a memory, the identified one or more messages after the one or more operations have been performed;
• executing the first set of instructions to identify the one or more messages on which to perform the one or more operations wherein executing the first set of instructions for each of the one or more messages in the first ordered data structure comprises:
• popping the message from the first ordered data structure;
• determining whether the message is to be acted upon based on the identified one or more operations comprising matching a routing key from the statement to a binding key of the message;
• determining, based on the identified one or more operations, whether to add the message back onto the first ordered data structure;
• and
• adding the message back onto the first ordered data structure when it is determined based on the identified one or more operations;
• executing the second set of instructions to perform the one or more operations on the identified one or more messages;
• executing the third set of instructions to store the one or more identified messages after the one or more operations have been performed;
• and
• transmitting the operated upon messages;
• and
• returning an error message when one of a statement including invalid syntax is received, an ordered data structure referenced in the statement does not exist, or that statement identifies an ordered data structure to be created that already exists.

A method of providing reorganization of messages in queuing systems, the method comprising:

• receiving a statement to reorganize one or more messages within a first queue;
• identifying one or more operations described in the statement that are to be performed on one or more messages in the first queue;
• identifying one or more messages logically stored between a first message in the first queue and a last message in the first queue on which to perform the one or more operations, wherein identifying each of the one or more messages logically stored between the first message in the first queue and the last message in the first queue comprises:
• popping the message from the first queue;
• determining whether the message is to be acted upon based on the identified one or more operations comprising matching a routing key from the statement to a binding key of the message;
• determining, based on the identified one or more operations, whether to add the message back onto the first queue;
• and
• adding the message back onto the first queue when it is determined based on the identified one or more operations;
• performing the one or more operations on the identified one or more messages;
• and
• returning the operated upon messages;
• and
• returning an error message when one of a statement including invalid syntax is received, an ordered data structure referenced in the statement does not exist, or that statement identifies queue to be created that already exists.