A publish-subscribe messaging method including: generating a modified first publication message by modifying a first publication message to include a reply-to property that directs a recipient device to acknowledge, to an acknowledgment queue, receipt of the first publication message; publishing the modified first publication message to (i) the acknowledgment queue and (ii) a consumer queue; responsive to the modified first publication message being consumed by one or more subscribers and/or a first timeout for the modified first publication message expiring, deleting the modified first publication message from the consumer queue; and responsive to the acknowledgment queue receiving an acknowledgment for the modified first publication message and/or a second timeout for the modified first publication message expiring, deleting the modified first publication message from the acknowledgment queue.

A method and system are provided for transactional messaging support in connected messaging networks. A first messaging network is provided which does not support transactional processing and a second messaging network is provided which does support transactional processing. A proxy application is provided between the first and second messaging networks. The proxy application receives messages from a first application on the first messaging network, the messages including instructions regarding transactional processing of the messages, and forwards the messages to the second messaging network using a transactional processing supported by the second messaging network.

In order to achieve location transparency and routing slip extensibility, a system and a method for orchestrating a web service using Business Process Execution Language are disclosed. The method includes: receiving a message, wherein the message comprises an address identifying an extension element; determining, from the address, a location of the extension element identified by the address; responsive to determining the location of the extension element, directing the message to an appropriate location; and storing the message in a computer readable storage medium.

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.

There is a need to provide a semiconductor device that improves an interrupt capability of a virtual machine. A semiconductor device includes a memory to store a plurality of virtual machines and a virtual machine manager to manage the virtual machines and a CPU to perform the virtual machines and the virtual machine manager. The CPU causes an active virtual machine to perform an interrupt process when information (first information) about an interrupt-processing virtual machine is equal to information (second information) about the active virtual machine. When the first information differs from the second information, the CPU causes the virtual machine manager to stop the active virtual machine and operates the interrupt-processing virtual machine to perform an interrupt process.

A method and related system to concurrently process a temporal message stream. The method comprises obtaining messages of a message stream, each message having an associated timestamp. The method further comprises storing each message in at least one of a plurality of queues, wherein the messages of each queue are ordered based on their timestamp such that a message with the earliest timestamp is positioned at the front of the queue. The method then comprises controlling retrieval of the target message from the front of a target queue based on a timing difference between the timestamp of the message and the timestamps of the front message of each of the other queues of the plurality of queues.

A method includes creating a publisher configured to send messages over a channel having a shared memory. The method includes creating at least one subscriber configured to receive the messages over the channel by sequentially referencing memory slots of the plurality of memory slots. The method includes determining that the next sequential memory slot is currently referenced by a subscriber. The method includes delaying sending the message by the publisher based on determining that the next sequential memory slot is currently referenced by the subscriber. The method includes receiving an event trigger indicative of message reading by the subscriber. The method includes, responsive to receiving the event trigger, determining that the next sequential memory slot is not currently referenced. The method includes sending the message to the next sequential memory slot based on determining that the next sequential memory slot is not currently referenced.

The present disclosure relates to a method for selecting and copying one or more characters of at least one of text or alphanumeric information appearing within a video image frame being displayed on a display of a client computing device, during a keyboard, video and mouse (KVM) session with a remote KVM appliance. The method enables a user to define text or alphanumeric information being displayed in a video frame on the display, using a control component of the client computing device, which the user desires to convert into text. The method uses an optical character recognition (OCR) software application to convert the selected video information into a text output. The text output can then be copied and pasted into one or more other applications, documents or web pages by the user for subsequent use.

Technology for determining whether an inter-process type message has been successfully sent from a first process to a second process running on a single computer with a single processor(s) set. A variable (for example, a bit value) is used to indicate whether the inter-process message has been communicated between the processes. A timer and a predetermined timeout threshold are used to determine if the inter-process message has been pending for too long without being successfully communicated.

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.