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.

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.

A system, method, and computer-readable medium for managing notifications delivered to a Virtual Reality (VR) device, including receiving, by a middleware application executing on the VR device, a notification from a server, the notification comprising a notification identifier, transmitting, by the middleware application, the notification to a notification plugin integrated with an active application executing on the VR device, activating, by the notification plugin, a notification application on the VR device, the notification application being configured to disable all other applications on the VR device and to display a notification message corresponding to the notification identifier in the environment rendered by the VR device, and deactivating the notification application in response to one or more of: receiving, by the notification plugin, a second notification comprising a second notification identifier matching the notification identifier, or detecting, by the notification application, a user acknowledgement of the notification message.

Embodiments of the present invention provide a method, system and computer program product for the integration of a rules engine with message oriented middleware. In an embodiment of the invention, a method for managing a messaging component in message oriented middleware has been provided. The method includes creating shared memory in the memory of a computer and adding or deleting tokens in the shared memory corresponding to objects such as messages and message queues, created in and removed from, respectively, in a messaging component of message oriented middleware. The method additionally includes applying rules in a rules engine to the tokens in the shared memory. Finally, the method includes directing management operations in the messaging component responsive to the applied rules by the rules engine.

An apparatus in one embodiment comprises at least one processing platform comprising a plurality of processing devices. The at least one processing platform is configured to provide a plurality of applications with centralized access to a plurality of message oriented middleware (MOM) servers via a connectivity layer, to establish a connection between a given one of the plurality of applications and a given one of the plurality of MOM servers via the connectivity layer, and to exchange data between the given one of the plurality of applications and the given one of the plurality of MOM servers via the connectivity layer.

A method may include receiving, from a client, an indication to include, in an application, a data processing pipeline implementing a data processing procedure that requires interaction with a data engine to retrieve and/or manipulate data in a data store coupled with the data engine. The application may be executed by exporting, to the data engine, a script corresponding to the data processing pipeline. Exporting the script may enable the data engine to execute the script to retrieve and/or manipulate data in the data store. The transfer of data resulting from the data engine executing the script may be monitored, for example, based on messages from the data engine. The messages may be exchanged via a message broker. Related systems and articles of manufacture, including computer program products, are also provided.

In various example embodiments, a system and method for synchronization of messages based on queues are presented. One or more electronic messages are received according a message order. A message queue that corresponds to the first user is generated. The one or more messages in the message queue are stored based on the received message order. A position of a next message in the generated message queue to be transmitted is determined. The message from the determined position in the message queue is transmitted to the client device operated by the first user.

Methods and systems for enhanced data reliability for sensor devices, such as Internet of Things (IoT) sensors can include a first set of sensor devices (e.g., primary sensors) for collecting data in accordance with an application program. A second set of sensor devices (peer sensors) can be enabled for collecting supplemental data. Each of the sensor devices in the second set of sensor devices corresponds to one of the sensor devices in the first set of sensor devices. After receiving data from a selected sensor device of the set of first sensor devices and determining that the received data triggers a notification for a critical event, a second sensor of the second set of sensor devices can be interrogated to confirm the critical event. The event is confirmed by a convergence of data from the selected sensor device and the supplemental data from the second sensor device.

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.

An embodiment of the present disclosure includes an RPC architecture that includes a central manager gateway with a client-facing side that allows for client access via web services protocols such as SOAP and REST. The central manager gateway further includes a server-facing side that can communicate with a plurality of network elements, with each network element implementing a common IDL architecture and RPC manager instance. Each of the network elements, and in particular their RPC manager instance, may communicate with other RPC manager instances to learn the network topology for the system and maintain a topology database for purposes of exposing a naming service, e.g., a CORBA naming service. The network elements may elect one master element while the others remain as slaves. The central manager gateway may automatically locate the master network element and forward client requests to the same for servicing.