Message broker customization with user administered policy functions
View Patent ↗Disclosed is a message broker apparatus, method, and program product customizable through the use of externally administered and executed policy functions. The system uses user defined and controlled policy functions to programmatically customize the behaviors of a message broker's processing of messages and further allowing for that customization to take place on a per channel basis. This provides for greater functionality and flexibility to the users of a message system, especially when the users of the message system do not have administrative control over the message broker.
1 . A first message broker apparatus comprising:
a one or more non-transitory computer readable storage mediums having a plurality of computer readable instructions recorded thereon;
a one or more first logic machines in a first execution environment configured for executing the plurality of instructions, wherein the plurality of instructions, when executed, configure the apparatus to:
(a) be administered by a first administrative domain;
(b) receive a one or more first messages from a one or more message producers;
(c) process a one or more second messages selected from the one or more first messages, resulting in a one or more third messages; and
(d) send a one or more of the one or more third messages to a one or more message consumers;
wherein the plurality of instructions, when executed, further configure the apparatus under (c) to:
(c1) process the one or more second messages in the first execution environment; and
(c2) invoke a one or more first policy functions, within a second execution environment distinct from the first execution environment, administered by a second administrative domain distinct from the first administrative domain, and utilizing a one or more second logic machines distinct from at least one of the one or more first logic machines, to process the one or more second messages.
2 . The first message broker apparatus according to claim 1 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions wherein processing performed by the one or more first policy functions is dynamically modifiable under the control of the second administrative domain.
3 . The first message broker apparatus according to claim 1 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more synchronous communications.
4 . The first message broker apparatus according to claim 3 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more remote procedure calls.
5 . The first message broker apparatus according to claim 3 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more function-as-a-service calls.
6 . The first message broker apparatus according to claim 1 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more asynchronous communications.
7 . The first message broker apparatus according to claim 6 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more application programming interface calls.
8 . The first message broker apparatus according to claim 6 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more function-as-a-service calls.
9 . The first message broker apparatus according to claim 6 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing the first message broker apparatus.
10 . The first message broker apparatus according to claim 6 , wherein the plurality of instructions, when executed, further configure the apparatus to invoke the one or more first policy functions utilizing a one or more second message broker apparatus distinct from the first message broker apparatus.
11 . A method for customizable message processing in a first message broker executing in a first execution environment and administered by a first administrative domain, the method comprising the steps of:
(a) receiving a first message from a message producer;
(b) processing the first message, resulting in a second message; and
(c) sending the second message to a message consumer;
wherein the step (b) further comprises the steps of:
(b1) processing the first message in the first execution environment; and
(b2) invoking a one or more first policy function, within a second administrative domain distinct from the first administrative domain, executing in a second execution environment distinct from the first execution environment, and processing the first message.
12 . The method of claim 11 , wherein the step (b2) further comprises the step of:
invoking the first policy function wherein a one or more first processing steps performed by the first policy function are dynamically modifiable under the control of the second administrative domain.
13 . The method of claim 11 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing synchronous communications.
14 . The method of claim 13 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing a one or more remote procedure calls.
15 . The method of claim 13 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing a one or more function-as-a-service calls.
16 . The method of claim 11 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing asynchronous communications.
17 . The method of claim 16 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing a one or more application programming interface calls.
18 . The method of claim 16 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing a one or more function-as-a-service calls.
19 . The method of claim 16 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing the first message broker.
20 . The method of claim 16 , wherein the step (b2) further comprises the step of:
invoking the one or more first policy function utilizing a one or more second message broker distinct from the first message broker.
21 . A computer program product having a non-transitory computer readable storage medium having computer readable program code recorded thereon for carrying out a method of customizable message processing in the operation of a first message broker, comprising:
(a) embodying a plurality of first instructions therein;
(b) executing a plurality of second instructions selected from the plurality of first instructions in a first execution environment to instantiate a first message broker;
(c) initializing the first message broker to be administered by a first administrative domain; and
(d) executing from the plurality of second instructions a method of customizable message processing, wherein the method of customizable message processing further comprises the steps of:
(d1) receiving a first message from a message producer;
(d2) processing the first message resulting in a one or more second messages; and
(d3) sending one or more of the second messages to a one or more message consumers;
wherein step (d2) further comprises the steps of:
(d2a) processing the first message in the first execution environment; and
(d2b) invoking a first policy function comprising a plurality of third instructions distinct from the plurality of second instructions within a second administrative domain distinct from the first administrative domain and executing in a second execution environment distinct from the first execution environment;
wherein the plurality of third instructions are dynamically modifiable under the control of the second administrative domain.