This invention discloses embodiments of a method and a system of distributed processing of transactions by a plural of participating applications, each acting asynchronously and independently from other participating applications. The method comprises using one or more configurable policy records, accepting from a participating application update of the state of the processing of a transaction and/or update of a configurable policy record of a transaction independent of the other participating applications, using a message manager to receive and stores one or more messages over time from one or more producers and distributes the messages to one or more subscribing consumers of the messages, and recording the states of processing of a transaction by the participating applications in a transaction state record. Each participating application starts or joins a transaction based on a policy, updates its state of processing in the transaction state record, and checks the policy record to determine its next action.

A machine learning system including a continuous embedding output layer is provided. Whereas traditional machine language translation or generation models utilize an output layer that include an single output for each word in the output vocabulary V, the present machine learning system includes a continuous embedding output layer that stores continuous vectors mapped to an m-dimensional vector space, where m is less than V. Accordingly, the present machine learning system processes an input string to produce an output vector and then searches for the continuous vector within the vector space that most closely corresponding to the output vector via, for example, a k-nearest neighbor algorithm. The system then outputs the output string corresponding to the determined continuous vector. The present system can be trained utilizing a cosine-based loss function.

A system or platform with architecture for dynamically orchestrating secure data flows across components in a healthcare enterprise, including, but not limited to, medical devices, electronic health records, clinical decision support systems, patient administration systems, and the like. The present invention enables plug-and-play interoperability via standards-based, trusted, bi-directional communication between components. The system provides dynamic registration of components and their profiles, runtime provisioning of communications channels, and dynamic orchestration of data between components. Component profiles abstract devices and applications as services producing and consuming certain messages that represent portions of a canonical data model. Registration takes a component identity and assigns an identifier and address to broker communication with the component. Dynamic orchestration uses registered component profiles and workflows to dynamically provision communication channels and initiate and manage data flow between components. The system also provides a process to remotely control medical devices via automated or semiautomated processes.

A system includes a cloud orchestration framework, a messaging interface and a plurality of cloud instances that each execute a respective messaging agent that transmits messages from the corresponding cloud instance to the messaging interface. Each of the cloud orchestration framework, messaging interface, and cloud instances respectively include at least one programmable data processor and memory storing instructions for execution by such at least one programmable data processor. The messages from each respective cloud instance have different message types corresponding to the operating system used by such cloud instance or an application-level event. In addition, the messaging interface queues the messages received from the cloud instances for processing by the cloud orchestration framework. Related apparatus, systems, techniques and articles are also described.

Flexible message transformation and delivery includes authenticating a message consumer for access to messages of a publisher, receiving from the consumer a service topology label identifying a service topology of a service of which the message consumer is a part, where the service topology label is used in controlling provision of messages to members of the service topology, identifying an authority label for the consumer, the authority label being associated with transformation(s) to apply to messages, and based on obtaining a message from the publisher for publishing to consumers that are members of the service topology: determining that the consumer is a member of the service topology, identifying the transformation(s) based on the identified authority label for the consumer; applying to the message the transformation(s) to obtain a transformed message, and providing the transformed message to the consumer.

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 and a method for modeling queue-based message-oriented middleware (MoM) are provided. The method commences with connecting with a MoM system and converting information associated with the MoM system into a standardized object model. The standardized object model may include a queue-based node, at least one producer application, and at least one consumer application. The at least one producer application provides a message to the queue-based node. The at least one consumer application receives the message from the queue-based node. The message persists in the queue until consumed by the at least one consumer application. The method continues with generating a standardized graph of relationships between a producer and a consumer over a period of time. The method further includes creating a policy, periodically analyzing the standardized graph for at least one deviation from the policy, and issuing an alert in response to detecting the at least one deviation.

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.

A method for messaging in a hybrid multi-cloud computing environment may include receiving, from a multi-cloud controller, a message. The hybrid multi-cloud computing environment may include multiple cloud platforms hosted on private, on premise infrastructure as well as public, third-party infrastructure. The multi-cloud controller may send the message to control an operation of the cloud platform. In response to receiving the message from the multi-cloud controller, the message may be deposited in message queue. The cloud platform may send a request to retrieve data destined for the cloud platform. The message from the message queue may be sent to the cloud platform in response to the request. Related systems and articles of manufacture, including computer program products, are also provided.

A system includes a cloud orchestration framework, a messaging interface and a plurality of cloud instances that each execute a respective messaging agent that transmits messages from the corresponding cloud instance to the messaging interface. Each of the cloud orchestration framework, messaging interface, and cloud instances respectively include at least one programmable data processor and memory storing instructions for execution by such at least one programmable data processor. The messages from each respective cloud instance have different message types corresponding to the operating system used by such cloud instance or an application-level event. In addition, the messaging interface queues the messages received from the cloud instances for processing by the cloud orchestration framework. Related apparatus, systems, techniques and articles are also described.