A total number of messages in a set of messages that are processed by a computing node in a virtual computer cluster during a time interval is determined. The virtual computer cluster is deployed with a cloud computing service and includes the computing node and other computing nodes at an end time of the time interval. It is determined whether the total number of messages in the set of messages processed by the computing node is no less than a maximum per-interval message number threshold. In response to determining that the total number of messages is no less than a maximum per-interval message number threshold, the cloud computing service is caused to start an additional computing node in the virtual computer cluster after the time interval, wherein the additional computing node is used to process one or more subsequent messages to be processed after the time interval.

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.

Systems and methods for novel uses and/or improvements to blockchains and blockchain technology. As one example, systems and methods are described herein for self-validating digital records that may be transferred in real-time through a cross-network registry. For example, in a conventional system, minting a token (e.g., a digital record) involves writing a self-executing program that defines the transfer rules of the digital record. Once the self-executing program is written, it is deployed on a blockchain, and the digital record is minted by publishing it to a blockchain.

A user interface method is provided by an SDK embedded in a third party resource running on a portable device including a camera and a display. The method includes receiving an API call to display an image processing user interface and in response, displaying a first user interface comprising a list of selectable graphical items corresponding to a group of available image modification features. If user selection of a desired graphical item from the list of selectable graphical items is received, image modification features corresponding to the desired graphical item are applied to an image received from the camera, generating a modified image. A second user interface including the modified image is then displayed on the display.

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 present disclosure is directed to a novel execution engine integration framework for a BFT SMR system. With this framework, execution engines for services can be integrated into the BFT SMR system in a generic manner, thereby avoiding the need to implement a custom request handling code for each individual service/execution engine.

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.

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.

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.

A system for directing messages between a composite user interface and at least one source application. A message is to be directed to a predetermined set of services, each service executes a command specified by the message and the message comprises details of the predetermined set of services. Each service in the predetermined set of services uses said details to determine whether the message should be sent to another service, and if it is determined that the message should be sent to another service transmits the message to an appropriate service.