A modular image processing SDK comprises an API to receive API calls from third party software running on a portable device including a camera. SDK logic receives and processes commands and parameters received from the API that are based on the API calls received from the third party software. An annotation system performs image processing operations on a feed from the camera based on image processing instructions and parameters received by the annotation system from the SDK logic. The image processing is based at least in part on augmented reality content generator data (or AR content generators), user input and sensor data.

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.

A message-level policy implemented with for a message routing system may be used to mediate between a variety of message sources and message targets that receive and use messages. The message-level policy may allow fine grained message-by-message policy assessment that a message routing system policy may be able to provide. The message-level policy may furthermore interact with the message routing system policy to provide mechanisms to avoid accidental leakage of protected messages or spill-over to protected regions.

Disclosed is a computer-implemented method for reducing write operations in a message system. The method includes receiving, by a message system, a message from a producer, wherein the message includes a first flag, the first flag indicating the message should be written to a recovery log, and the message is configured to be sent to a consumer. The method also includes adding the message to a queue. The method further includes determining, at a first time, the consumer is not available. The method includes verifying, in response to the consumer not being available at the first time, a trigger is not met. The method also includes determining, at a second time, the consumer is available. The method also includes sending, in response to determining the consumer is available, the message to the consumer.

A method for providing data streams to a consuming client over a network interface wherein the data streams comprise message data streams based on streaming nodes indicative of message topics configured for storing and streaming message data, wherein each of the streaming nodes represents a data source device, and wherein interconnections between the streaming nodes define relationships between the streaming nodes is disclosed. The method comprises, by a routing component; receiving (101), from a consuming client, a request comprising a query for a set of streaming nodes and corresponding data, wherein each streaming node of the set of streaming nodes is associated with each other via one or more interconnections in the set of streaming nodes, obtaining (104) a container comprising the set of streaming nodes and corresponding data from a database based on the query of the received request, wherein the corresponding data comprises at least one message stored in a streaming node of the set of streaming nodes, deriving (105) correlated data based on the obtained container, and providing (107), to the consuming client, the set of streaming nodes and the derived correlated data in message data streams. Corresponding computer program product, arrangement, routing component, and system are also disclosed.

A system and a method for routing a message to an application over a connection oriented session in a Kafka messaging platform environment are provided. The method includes: acquiring a plurality of partitions from the Kafka messaging platform; designating a first partition from among the plurality of partitions as a sticky partition; generating a plurality of routing keys that are configured to route to the sticky partition; receiving a subscription from a service that corresponds to a first application; transmitting, to the first application, a first routing key that identifies the subscription from among the plurality of routing keys; and receiving messages from Kafka services that are routed by the first routing key to the first application. For any particular application or set of applications, a plurality of connection oriented sessions may be used to achieve load balancing and high availability.

The present disclosure provides an exception stack handling method, system, electronic device and storage medium and relates to the field of mobile Internet. The method may include: at the level of any executor in a distributed stream-type processing system including at least two executors, performing the following processing of: obtaining at least one exception stack from a message middleware when the executor in an idle state each time, collected exception stacks generated by users being stored in the message middleware; as for any exception stack, obtaining an anti-obfuscation map file corresponding to the exception stack, and performing anti-obfuscation processing for the exception stack by using the anti-obfuscation map file. The solution of the present disclosure may be applied to improve the processing speed.

A computer-implemented method can receive a software update for a software application deployable on a target system and perform an automatic performance test of the software application incorporating the software update on the target system. The automatic performance test can be integrated in a continuous integration and continuous delivery (CI/CD) pipeline. The method can collect a plurality of performance metrics measured when performing the automatic performance test and determine a performance score based on the plurality of performance metrics. Responsive to detecting the performance score is below a predefined performance threshold, the method can cause the CI/CD pipeline to reject the software update to the software application.

A computing architecture providing for rapid analysis and control of an environment via edge computing nodes is disclosed. Input data streams may be captured via one or more data stream independent CPU threads and prepared for processing by one or more machine learning models. The machine learning models may be trained according to different use cases to facilitate a multi-faceted and comprehensive analysis of the input data. The evaluation of the input data against the machine learning models may be facilitated via independent GPU threads (e.g., one thread per model or use case) and the outputs of the models may be evaluated using control logic to produce a set of outcomes and control data. The control data may be utilized to generate one or more command messages that may provide feedback to a remote device or user regarding a state of a monitored environment or other observed condition.

A computer system that processes state messages is described. During operation, the computer system receives, associated with communication network devices in a network, the state messages, where the state messages include different types of state messages having associated priorities. Then, the computer system computes identifiers of the state messages based at least in part on second identifiers of clients associated with or connected to the communication network devices, where, for a given state message, the computer system computes an identifier of the given state message based at least in part on a second identifier of a given client associated with information in the given state message. Next, the computer system may selectively assign the state messages to dedicated message queues having associated processing priorities based at least in part on the computed second identifiers and/or the types of state messages.