Agent message delivery fairness
Apparatus and methods are disclosed for generating, sending, and receiving messages in a networked environment using autonomous (or semi-autonomous) agents. In one example of the disclosed technology, a method of controlling message flow in a computer network comprising a plurality of agents, agent data consumers, and an agent message bridge configured to send messages by receiving a set of messages, at least some of the messages including a message type, queuing the set of messages in a spooler that includes an indication of the respective message type for each of the messages, receive an indication that sending some of the messages queued in the spooler should be delayed for one or more indicated message types, and sending at least one of the messages to a selected one or more of the agent data consumers, the sent messages not being of the indicated message types.
1. At least one computer-readable storage medium storing computer-executable instructions, which when executed by a processor in communication with a server, cause the server to perform a method, the computer-executable instructions comprising:
instructions that cause the server to send a message to at least one agent executing on a compute host indicating a message type of a plurality of message types via a communication connection;
instructions that cause the server to send advisory messages to the at least one agent instructing to hold all messages having one or more message types of the plurality of message types while still forwarding all messages having a message type other than the one or more message types, wherein the one or more message types are not all of the plurality of message types;
instructions that cause the server to send a subsequent advisory message indicating that the agent should resume sending of messages having at least one of the one or more message types; and
instructions that cause the server to receive host data from the at least one agent, wherein at least some of the received host data has been stored at the compute host when the at least one agent cannot send data to the server via the communication connection.
2. The computer-readable storage medium of claim 1 , wherein the computer-executable instructions further comprise:
instructions that cause the server to send the host data to at least one agent data consumer.
3. The computer-readable storage medium of claim 1 , wherein the computer-executable instructions further comprise:
instructions that cause the server to send the received host data to at least one agent data consumer selected based on an agent identifier indicated by a message received from the host computer.
4. The computer-readable storage medium of claim 1 , wherein the computer-executable instructions further comprise:
instructions that cause the server to monitor one or more message topics; and
instructions that, when a number of message topics reaches a configurable limit, cause the server to send an advisory message to one or more agents indicating to stop sending or restart sending of messages according to at least one of the message topics.
5. The computer-readable storage medium of claim 1 , wherein the computer-executable instructions further comprise:
instructions that cause the server to send a message to the at least one agent to adjust the rate at which messages are sent to the server.
6. A server, comprising:
at least one processor;
a communication connection operable to communicate with the at least one agent executing on a host computer; and
a computer-readable storage medium storing computer-executable instructions, which when executed by the at least one processor, cause the at least one processor to perform a method, the computer-executable instructions comprising:
instructions that cause the at least one processor to send a message to at least one agent executing on a compute host indicating a message type of a plurality of message types via a communication connection;
instructions that cause the at least one processor to send advisory messages to the at least one agent instructing to hold all messages having one or more message types of the plurality of message types while still forwarding all messages having a message type other than the one or more message types, wherein the one or more message types are not all of the plurality of message types;
instructions that cause the at least one processor to send a subsequent advisory message indicating that the agent should resume sending of messages having at least one of the one or more message types; and
instructions that cause the at least one processor to receive host data from the at least one agent, wherein at least some of the received host data has been stored at the compute host when the at least one agent cannot send data to the server via the communication connection.
7. The server of claim 6 , further comprising:
a message broker means for a temporarily storing the received host data.
8. The server of claim 6 , wherein the computer-executable instructions further comprise:
instructions that cause the at least one processor to send the host data to at least one agent data consumer.
9. The server of claim 6 , wherein the computer-executable instructions further comprise:
instructions that cause the at least one processor to send the received host data to at least one agent data consumer selected based on an agent identifier indicated by a message received from the host computer.
10. The server of claim 6 , wherein the computer-executable instructions further comprise:
instructions that cause the at least one processor to monitor one or more message topics; and
instructions that, when a number of message topics reaches a configurable limit, cause the at least one processor send an advisory message to one or more agents indicating to stop sending or restart sending of messages according to at least one of the message topics.
11. The server of claim 6 , wherein the computer-executable instructions further comprise:
instructions that cause the at least one processor to send a message to the at least one agent to adjust the rate at which messages are sent to the server.
12. A method comprising:
communicating, by at least one processor in communication with a server, with at least one agent executing on a host computer; and
sending, by the at least one processor, a message to at least one agent executing on a compute host indicating a message type of a plurality of message types via a communication connection;
sending, by the at least one processor, advisory messages to the at least one agent instructing to hold all messages having one or more message types of the plurality of message types while still forwarding all messages having a message type other than the one or more message types, wherein the one or more message types are not all of the plurality of message types;
sending, by the at least one processor, a subsequent advisory message indicating that the agent should resume sending of messages having at least one of the one or more message types; and
receiving, by the at least one processor, host data from the at least one agent, wherein at least some of the received host data has been stored at the compute host when the at least one agent cannot send data to the server via the communication connection.
13. The method of claim 12 , further comprising:
temporarily storing, by the at least one processor, the received host data.
14. The method of claim 12 , further comprising:
sending, by the at least one processor, the host data to at least one agent data consumer.
15. The method of claim 12 , further comprising:
sending, by the at least one processor, the received host data to at least one agent data consumer selected based on an agent identifier indicated by a message received from the host computer.
16. The method of claim 12 , further comprising:
monitoring, by the at least one processor, one or more message topics; and
when a number of message topics reaches a configurable limit, sending, by the at least one processor, an advisory message to one or more agents indicating to stop sending or restart sending of messages according to at least one of the message topics.
17. The method of claim 12 , further comprising:
sending, by the at least one processor, a message to the at least one agent to adjust the rate at which messages are sent to the server.