A message transformation program consisting of key-value pairs that represent executable instructions is used to transform data exchanged in messages having different message formats and schemas between two enterprises with an enterprise integration system. The message transformation program is written in a programming language having program constructs that enable a developer to generate a message transformation program to transform data between disparate message formats and schemas regardless of the message format and schema used in a message.

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.

For energy operations across domains, a method generates a native node and a foreign node that includes a foreign data structure that is defined with a foreign protocol and that represents information of a foreign device in a foreign namespace. The method links the native node and the foreign node in a native namespace and the foreign namespace by a translation function that automatically converts information between the foreign data structure and the proxy data structure using protocol specific structure converting functions. The method further establishes a first publish/subscription instance with message middleware for the foreign device as publisher of the first publish/subscription instance. The method translates a message from the foreign device using the communication stack.

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.

A method and system are provided for transactional messaging support in connected messaging networks. A first messaging network is provided which does not support transactional processing and a second messaging network is provided which does support transactional processing. A proxy application is provided between the first and second messaging networks. The proxy application receives messages from a first application on the first messaging network, the messages including instructions regarding transactional processing of the messages, and forwards the messages to the second messaging network using a transactional processing supported by the second messaging network.

Managing tasks using an application-level blue-green topology with parallel cell infrastructure rails. Each cell infrastructure rail includes a dispatcher bot and a performer bot. The dispatcher bot is configured to prepare a work task based on a received request, and the performer bot performs the work task, resulting in performed work. A discovery server includes a service registry configured to store the states of the infrastructure rails. The discovery server receives the request for the work task, and sends the request to a dispatcher bot of a specific cell infrastructure rail based on the request and the states of the cell infrastructure rails. A respective workflow cell server receives the performed work. In the case that one cell infrastructure rail experiences a problem when processing the request, the cell infrastructure rails are switched to perform the request on the other cell infrastructure rail. The method implements the system.

A computing system for a vehicle may include processors to execute instructions to receive, by a middleware software layer of the computing system, messages published by one or more of a plurality of autonomous processing modules, and determine, by the middleware software layer, and based on the published messages, whether a similarity comparison of a first vehicle parameter and a second vehicle parameter satisfy a similarity threshold value. The first vehicle parameter and the second vehicle parameter relate to the messages published by the one or more autonomous processing modules. In response to determining that the similarity comparison of the first vehicle parameter and the second vehicle parameter does not satisfy the similarity threshold value, provide, by the middleware software layer, an instruction to a control system to cause the vehicle to perform an action, and cause, by the control system, the vehicle to perform the action.

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.

A system includes one or more memory devices storing instructions, and one or more processors configured to execute the instructions to perform steps of a method for providing real time message processing using an event driven framework. The system may generate an event associated with a particular topic by a producer component and place the event into an event queue associated with the topic that is maintained by a broker device. A consumer component associated with the topic may then process the event and execute a predetermined consumer action. The system may then select a communication medium used to transmit a notification to the customer based on customer behavior information.

A method and system are provided for transactional messaging support in connected messaging networks. A first messaging network is provided which does not support transactional processing and a second messaging network is provided which does support transactional processing. A proxy application is provided between the first and second messaging networks. The proxy application receives messages from a first application on the first messaging network, the messages including instructions regarding transactional processing of the messages, and forwards the messages to the second messaging network using a transactional processing supported by the second messaging network.