摘要:
A data processing method for optimizing one or more parameters of a message handling system comprises defining a test workload comprising a plurality of messages, simulating the normal operation of the message handling system, processing at least a portion of the test workload, changing one or more parameters of the message handling system, monitoring the performance of the message handling system, and generating an optimization of at least one parameter based upon the performance of the message handling system.
摘要:
For processing messages in a messaging system comprising a source and a destination queue manager, an uncommitted message is received from an application at the source queue manager. This is transmitted to the destination queue manager and received thereat. When it is determined that the message is uncommitted, it is stored in memory, rather than placing the message on a receive queue for processing by another application. If it is determined that the uncommitted message has been committed by the application which originated the uncommitted message, then it is placed on the receive queue.
摘要:
Message content associated with at least one message received by a message processing server is stored in association with the message processing server. The message content within an incoming message is compared with the stored message content. A determination is made as to whether the stored message content is duplicated by the message content associated with the incoming message. A duplicate message content management action is performed based upon the determination as to whether the stored message content is duplicated by the message content associated with the incoming message. This abstract is not to be considered limiting, since other embodiments may deviate from the features described in this abstract.
摘要:
This system detects and corrects looping problems in a publish-subscribe messaging network. This system requires a token which uniquely identifies a node in this network or universally unique in this messaging network. This system maintains a list of Universally Unique Identifiers (UUID) as a metadata attached to each publish-subscribe message (“publication”). As a node forwards a publication to another node, it is required to append its own UUID to this list or discard the message if its UUID already is in the attached list. Several nodes could form a broker cooperative aggregate node and have a unique identifier for all the nodes in the cooperative if they have an internal mechanism for preventing publication looping.
摘要:
A method for resolving a unit of work involving a plurality of participants, for use in a publish/subscribe system having a plurality of participants that subscribe to a first topic and at least one component having access to an outcome associated with the unit of work. The component publishes, to the first topic, a first message comprising a first outcome associated with the unit of work. If there is a failure associated with a first participant, a second participant use the published outcome to recover the unit of work.
摘要:
A computer system with a first messaging application communicates a message to another computer system with a second messaging application via a coupling facility storage device. If the message does not exceed a predetermined threshold, the message is put onto the queue in the coupling facility. If the message does exceed a predetermined threshold, the message is put onto a log associated with the first messaging application and readable by the second messaging application. A pointer to the message is put onto the queue in the coupling facility. The pointer can be used to access the message in the log.
摘要:
Responsive to a client application initiating a synchronous communication with a server application by sending a request via an asynchronous communication manager, one or more checks are performed to identify a cause of any failure to provide a response to the client application satisfying synchronous communication criteria. The results of one or more checks are used to determine whether to back out any data updates performed by/on behalf of the server application in response to the request.
摘要:
This system detects and corrects looping problems in a publish-subscribe messaging network. This system requires a token which uniquely identifies a node in this network or universally unique in this messaging network. This system maintains a list of Universally Unique Identifiers (UUID) as a metadata attached to each publish-subscribe message (“publication”). As a node forwards a publication to another node, it is required to append its own UUID to this list or discard the message if its UUID already is in the attached list. Several nodes could form a broker cooperative aggregate node and have a unique identifier for all the nodes in the cooperative if they have an internal mechanism for preventing publication looping.
摘要:
A computer system with a first messaging application communicates a message to another computer system with a second messaging application via a coupling facility storage device. If the message does not exceed a predetermined threshold, the message is put onto the queue in the coupling facility. If the message does exceed a predetermined threshold, the message is put onto a log associated with the first messaging application and readable by the second messaging application. A pointer to the message is put onto the queue in the coupling facility. The pointer can be used to access the message in the log.
摘要:
Systems methods and computer programs are disclosed that enable generating transaction messages. In one embodiment, the method comprises: generating a transaction message using a first computing device, the transaction message comprising: compensation information comprising instructions indicating a transaction to be executed in order to undo a previously executed transaction; and a transaction identification that identifies an executing program within the first computing device to execute the transaction; and sending the transaction message over an input/output device connected to the first computing device for processing on a second computing device.