A system, method and computer program product are provided for sharing information in an automobile vehicle comprising: receiving information in the form of a packet data unit representing datum information carried by an overall message from a first physical network selected from the group consisting of FlexRay, Controller Area Network, Local Interconnect Network and Media Oriented Systems Transport; in response to the receipt of the information, issuing a storage resource request in connection with a storage resource; determining whether the storage resource is available for storing the information; determining whether a threshold has been reached in association with the storage resource request; in the event the storage resource is not available and the threshold associated with the storage resource request has not been reached, issuing another storage resource request in connection with the storage resource; in the event the storage resource is available, storing the information in the storage resource; and sharing the stored information with at least one of a plurality of heterogeneous processes including at least one process associated with a second physical network selected from the group consisting of FlexRay, Controller Area Network, Local Interconnect Network and Media Oriented Systems Transport, utilizing a network protocol different from a protocol of the first physical network.

Disclosed herein are system, method, and computer program product embodiments for creating mapping programs between a source system and a target system. An embodiment operates by selecting a set of source and target messages in a middleware system. The embodiment creates a message collection in a message collection store system based on a set of messages. The embodiment creates a new or updated mapping program automatically between the source and target messages on the basis of historical messages from the message store.

Disclosed is 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.

Aspects of the disclosure relate to message processing. A computing platform may intercept an application message, which may be directed to a message bus. The computing platform may input the application message into a model, which may output a message priority score for the application message. The computing platform may compare, using the model, the message priority score to a message priority threshold. Based on identifying that the message priority score does not exceed the message priority threshold, the computing platform may route the application message to a message storage system rather than the message bus. The computing platform may monitor the message bus to detect available processing capacity. Based on identifying that the available processing capacity meets or exceeds a message processing threshold, route the application message to the message bus.

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.

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.

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 system, method and computer program product are provided for sharing information in an automobile vehicle comprising: receiving information in the form of a packet data unit representing datum information carried by an overall message from a first physical network selected from the group consisting of FlexRay, Controller Area Network, Local Interconnect Network and Media Oriented Systems Transport; in response to the receipt of the information, issuing a storage resource request in connection with a storage resource; determining whether the storage resource is available for storing the information; determining whether a threshold has been reached in association with the storage resource request; in the event the storage resource is not available and the threshold associated with the storage resource request has not been reached, issuing another storage resource request in connection with the storage resource; in the event the storage resource is available, storing the information in the storage resource; and sharing the stored information with at least one of a plurality of heterogeneous processes including at least one process associated with a second physical network selected from the group consisting of FlexRay, Controller Area Network, Local Interconnect Network and Media Oriented Systems Transport, utilizing a network protocol different from a protocol of the first physical network.

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 listwhere it is eligible to be matched against other, contra-side electronic data messages.

A system, method and computer program product are provided for receiving information associated with a message, issuing a storage resource request in connection with a storage resource and determining whether the storage resource is available. In use, the information is capable of being shared in less than one second, utilizing an automotive electronic control unit which includes a plurality of interfaces.