摘要:
Provided are a message brokering systems, computer program products and methods for communication in a publish/subscribe environment in which publisher application programs send messages to subscriber application programs via one or more message brokers, the method comprising the following steps: responsive to receipt of a published message at a message broker, referring to characteristics of the received message and subscriber-specified quality of service requirements to determine an appropriate quality or service for onward transmission of the message; selecting a communication protocol in accordance with the determined quality of service; and transmitting the message using the selected communication protocol. Information relating to the quality of service requirements of a first message broker's subscribers is passed to other brokers and subsequently used for selection of an appropriate communication protocol for transmitting messages between the brokers.
摘要:
Provided are a message brokering systems, computer program products and methods for communication in a publish/subscribe environment in which publisher application programs send messages to subscriber application programs via one or more message brokers, the method comprising the following steps: responsive to receipt of a published message at a message broker, referring to characteristics of the received message and subscriber-specified quality of service requirements to determine an appropriate quality or service for onward transmission of the message; selecting a communication protocol in accordance with the determined quality of service; and transmitting the message using the selected communication protocol. Information relating to the quality of service requirements of a first message broker's subscribers is passed to other brokers and subsequently used for selection of an appropriate communication protocol for transmitting messages between the brokers.
摘要:
A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.
摘要:
Dynamically collecting data pertaining to a program execution. A method can include monitoring execution of the program in a plurality of threads and, responsive to identifying an exception triggered by the program execution in a first of the plurality of threads, initiating at least one data collector to collect data exclusively relevant to the program execution in the first thread.
摘要:
A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.
摘要:
A data processing network in which a plurality of workstations such as personal computers (PC) (12) are connected to a host processor (11) and contain PC programs at particular levels for controlling tasks on the personal computers. The personal computers send a signal to the host when they are about to conduct a task indicating which data files they have and at what level. The host has an object library containing a copy of each disk file for each version of PC program. The host determines if the personal computer has the latest level data file for the version of program at that personal computer and, if it does not, sends a copy of the latest level data file to the personal computer to replace the down-level data file. Preferably, the host checks if the personal computer has all the data files it needs for the particular task and, if it does not and if it should because of the version of PC program stored at the PC, the host can load a copy of the missing file to the personal computer. The host does not have to contain a record of all the levels of all the programs of all the personal computers connected to it. However, by updating the object library in the host, this arrangement ensures that all personal computers connected to it are automatically brought to the latest authorized level of data files as are required by the personal computer.