A method may include receiving, from a client, an indication to include, in an application, a data processing pipeline implementing a data processing procedure that requires interaction with a data engine to retrieve and/or manipulate data in a data store coupled with the data engine. The application may be executed by exporting, to the data engine, a script corresponding to the data processing pipeline. Exporting the script may enable the data engine to execute the script to retrieve and/or manipulate data in the data store. The transfer of data resulting from the data engine executing the script may be monitored, for example, based on messages from the data engine. The messages may be exchanged via a message broker. Related systems and articles of manufacture, including computer program products, are also provided.

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

A system and a method for providing resiliency in a telephony communication system are provided. The method includes: receiving registration information that relates to a requested service, the registration information including a service name, a resource identifier such as a directory number, at least one pool, and status information; and mapping the received registration information to a database that associates the name of the requested service with the resource identifier and each pool and associates each pool with the status information; and transmitting at least two Uniform Resource Locators (URLs), including a primary URL and a backup URL, for providing the requested service.

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.

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 approach to tracking application transactions without modifications to the application. Receiving a message from a first application. Creating a temporary message identity and a temporary data structure. Configuring the temporary message to save tracking information. Calling the first application to retrieve the tracking information. Saving the tracking information and sending the message to a second application.

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.

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

A system and a method for processing a message on a processing platform, such as a Kafka processing platform, are provided. The method includes: acquiring a plurality of partitions from the 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 messages to the sticky partition; using a first routing key from among the plurality of routing keys to identify a first service subscription; subscribing to a second service using the first routing key; and receiving a message transmitted by the second service.