A message broker customization system and method with user administered 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.

The described technology relates to a publish-subscribe message framework in which an application, decomposed to a plurality of processing stages, is run by executing respective processing stages of the application asynchronously and simultaneously with each other. Communications between the respective processing stages may exclusively be in accordance with the publish-subscribe execution model. The described publish-subscribe framework provides for processing stages to be executed in a multi-process and/or multi-threaded manner while also enabling the distribution of the processing stages to respective processing resources in a multi-processor/multi-core processing environment. An example electronic exchange application and a corresponding example exchange gateway application are described.

This document discloses techniques, apparatuses, and systems for inter-service communication management to manage inter-service communication between a server-side service and a client-side service. The inter-service management system may comprise memory and a controller configured to perform the inter-service communication management. In aspects, a configuration file may be used to obtain information specifying a first inter-service communication mechanism for communicating one or more messages between the client-side and server-side services. The inter-service communication management system may instantiate a stub associated with the inter-service communication mechanism information, which can be used to communicate a message from the server-side service to a proxy that interacts with the client-side service. The message may then be forwarded from the proxy to the client-side service to enable inter-service communication between the server-side service and the client-side service.

A system for secure processing of intra-processor data comprising firmware configured to operate on a processor. An operating system configured to operate on the processor. Payload configured to operate on the processor. An embedded controller coupled to the firmware, the operating system and the payload, wherein the embedded controller is configured to enable messaging between the firmware, the operating system and the payload.

Some embodiments of a system and a method to automatically deploy message queues on-demand in a computing system have been presented. An application server may configure an application messaging service according to a set of rules in a configuration file. In response to applications requesting to access messaging queues for the first time, the application server may automatically deploy messaging queues on-demand following the set of rules in the configuration file.

A distributed computer system is provided. The distributed computer system includes at least one sequencer computing node and at least one matcher computing node. Electronic data messages are sequenced by the sequencer and sent to at least matcher computing node. The matcher computing node receives the electronic data messages and a reference value from an external computing source. New electronic data messages are put into a pending list before they can be acted upon by the matcher. A timer is started based on a comparison of the reference value (or a calculation based thereon) to at least one attribute or value of a new electronic data message. When the timer expires, the electronic data message is moved from the pending list to another list—where it is eligible to be matched against other, contra-side electronic data messages.

The present disclosure is related to a message processing method, which belongs to the field of information processing techniques. The message processing method includes: receiving a first request comprising a first resource identifier; determining whether the first resource identifier exists in a group resource comprising a plurality of second resource identifiers and group members corresponding to the second resource identifiers one by one; and sending the first request to other group member in the group resource than the group member corresponding to the first resource identifier when determining that the first resource identifier exists in the group resource.

In some examples, a technique may include outputting information associated with a notification. The notification may be associated with a notification attribute. The technique may further include determining, by a computing device, that a user has perceived the information associated with the notification; and receiving, by the computing device, an indication of at least one physiological parameter representative of a reaction of the user to the information associated with the notification. In some examples, the technique also includes, responsive to receiving the indication of the at least one physiological parameter representative of the reaction of the user to the information associated with the notification, controlling, by the computing device, at least one notification configuration setting related to outputting information associated with other notifications associated with the notification attribute.

Adapted positioning information is provided towards at least one consuming application regarding a plurality of objects. In a first step, the position of at least one specific object is detected using at least one sensor of a sensor layer or functionality, thereby generating at least one piece of preliminary positioning information. In a second step, subsequent to the first step, a positioning middleware functionality generates at least one piece of adapted positioning information, based on the at least one piece of preliminary positioning information, and based on a priori knowledge. In a third step, subsequent to the second step, the at least one piece of adapted positioning information is provided to the at least one consuming application.

Methods and systems are provided for processing a stream of incoming messages sent from a specific input message source and validating each incoming message of that stream before sending them to a specific target system.