摘要:
Input to a transformation engine is produced, responsive to a client computer providing a data access service (DAS) computer with XML data for transformation, by creating a graph shell and XML store for the XML data, determining if the graph has a store; and, if so, requesting an empty TrAX result; requesting to fill the empty TrAX result using TrAX source, and requesting a store parser for events related to the XML store; while avoiding wrapping by the TrAX DAS of a graph shell with TrAX source, requesting by a TrAX source of a graph for one or more nodes, requesting by a graph from a store for one or more nodes, parsing of a buffer by a store, returning events from a store to a graph, building of a graph by the same graph, returning nodes from a graph to a TrAX source; and building events by a TrAX source.
摘要:
A data processing method, apparatus, computer program product, and service for assuring timely execution of compensation for non-transactional work which is carried out in a transaction under which a data item is processed. A lock is taken before the data item is processed and, in the event the transaction fails, the same lock is also obtained before the data item is re-processed. As a result, re-processing of the data item is held until the lock obtained by the failed transaction is released and this is only done once compensation of non-transactional work is complete. Thus, compensation completes before the message is re-processed.
摘要:
A method of ordering multiple resources in a transaction includes receiving a transaction for a plurality of resources and determining, for each resource, the work embodied by the transaction. The method further may include specifying an order of the resources according to the determination of the work, committing the transaction, and invoking the resources in the specified order. Specifying the order of the resources may include specifying the resource to be invoked last. Alternatively, or additionally, specifying the order of the resources also may include specifying that each resource carrying out read-only work be invoked first.
摘要:
A data processing apparatus for carrying out a specific business logic data processing task, has a plurality of business activities running on at least one data processing machine, each activity communicates with other activities via a communications protocol in order to carry out the specific business logic data processing task. At least one of the activities includes a plurality of message broker data processing nodes.
摘要:
Provided are a method, system, and program for generating asynchronous interfaces and methods from synchronous interfaces and methods receiving a synchronous interface to a target component having a synchronous method used by a client component to synchronously invoke the target component. An asynchronous interface is generated for the synchronous interface of the target component. An asynchronous method is generated for the generated asynchronous interface having arguments to invoke the target component, wherein the client calls the generated asynchronous method to cause an asynchronous execution of the synchronous method.
摘要:
Disclosed is data processing apparatus comprising: means for receiving inputs indicative of results from one or more participants of said one or more sets of data processing tasks; means for mapping each of said inputs to a corresponding mapped value by accessing a mapping table; outcome processor means for accepting the mapped values as inputs and determining an outcome for said one or more sets of data processing tasks; and means, responsive to said means for determining, for transmitting an indicator of said outcome to said one or more participants; wherein the inputs and mapped values of the mapping table are programmably changeable to thus provide a high degree of flexibility with respect to said inputs.
摘要:
Transforming an original message from an application executed by a physical computing device to create a message readable by a plurality of heterogeneous recipients includes: creating with the physical computing device a first sub-message having data from the original message that is readable by each of the heterogeneous recipients; creating with the physical computing device a second sub-message having data from the original message that is not readable by each of the heterogeneous recipients; and generating with the physical computing device a composite message including both the first sub-message and the second sub-message.
摘要:
Message type validation occurs at a message producer before a message is sent to a message destination. A message producer system includes an administrator component, which stores message type parameters associated with a message destination. A message is created for the message destination and a validation component at the message producer system checks the created message for conformity with the stored message type parameters for the message destination. An error is reported if the message type does not conform to the stored message type parameters associated with the message destination. The validation component checks the created message for conformity after a publish call by the message producer system and before a send call and, therefore, prevents an invalid or non-conforming message from being sent.
摘要:
Transforming an original message from an application executed by a physical computing device to create a message readable by a plurality of heterogeneous recipients includes: creating with the physical computing device a first sub-message having data from the original message that is readable by each of the heterogeneous recipients; creating with the physical computing device a second sub-message having data from the original message that is not readable by each of the heterogeneous recipients; and generating with the physical computing device a composite message including both the first sub-message and the second sub-message.
摘要:
A method of ordering multiple resources in a transaction comprising receiving a transaction for a plurality of resources; determining, for each resource, the work embodied by the transaction; ordering the resources according to the determination of the work; committing the transaction; and invoking the resources in the selected order. The step of ordering the resources may comprise specifying the resource to be invoked last. Alternatively, or additionally, the step of ordering the resources may also comprise specifying that each resource carrying out read-only work is to be invoked first.