Patent ID: 9680919
Date: 2017-06-13
CPC Classifications: G06F,H04L,H04W

Claim:
1. A computer system comprising a plurality of computing nodes connected in a network, wherein: each said node of the plurality of computing nodes includes processing resources including at least one processor and an interface to the network; each said node of the plurality of computing nodes is dynamically configurable to use one of a brokered communication model and a brokerless communication model to send and/or receive messages over the network via the respective interface to the network, at least one node of the plurality of computing nodes being configured to send and/or receive messages using the brokered communication model and at least one other node of the plurality of computing nodes being configured to send and/or receive messages using the brokerless communication model; each node of at least a subset of nodes of the plurality of computing nodes including a complex event processing (CEP) engine deployed thereto, the CEP engines being configured to cooperate with the processing resources of the respective nodes to which the CEP engines are deployed in order to process messages received by the respective nodes before transmitting the processed message to another node, the CEP engines being classified as one of at least two different types of CEP engines, at least one node of the subset of nodes having a first type of CEP engine deployed thereto and at least one other node of the subset of nodes having a second type of CEP engine deployed thereto; and for each message, received by a given node, to be forwarded to a further node along one of plural possible paths, the given node is configured to use the processing resources and interface to the network of the given node to route the message to be forwarded to an intermediate node in one of the plural possible paths, the intermediate node being selected from the plurality of computing nodes by the CEP engine of the given node based on metadata associated with the message to be forwarded, wherein at least one of the plurality of computing nodes is dynamically configurable to use one of the brokered communication model and the brokerless communication model based on predicted and/or observed conditions of the network or one or more of the nodes of the plurality of computing nodes.