摘要:
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.
摘要:
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.
摘要:
A method, apparatus and computer program are disclosed for refusing to process messages from a sender at a queue manager associated with a receiver when the receiver is inactive. It is identified whether a first destination has been selected. This first destination provides an indication of whether the receiver is active. If a first destination has been selected, it is determined using this first destination whether the receiver is active. If the receiver is inactive, the queue manager refuses to process messages intended for the receipt by the receiver.
摘要:
A method for resolving a unit of work involving a plurality of participants, the method comprising the steps of: generating logic comprising an identifier generator; aggregating the logic with an owning application of a unit of work; and in response to the owning application initiating the unit of work, generating, by the identifier generator, an identifier associated with the unit of work.
摘要:
A system, method, apparatus, and computer program product uses a plurality of message transmitters to achieve high availability message transmission. The plurality of message transmitters are each operable to transmit a message to a subscriber. In accordance with a determination, for example, of the value of the connections, the message is copied and transmitted to the plurality of the message transmitters so that at least one of the plurality of message transmitters transmits the copy to the subscriber. The at least one message transmitter may be selected by analyzing the message and determining an associated rule based on characteristics of the message.
摘要:
A tracking system includes a business system using a plurality of application modules each including a computer for processing a transaction including a plurality of steps. A messaging system includes a messaging computer program embodied in a computer readable medium in each of the computers for communicating between the computers. The messaging system generates queues of messages being communicated between the computers. The messaging system can be configured by an administrator to generate tracking data about the messages being communicated between the computers. A tracking module is included in one of the computers, and has the messaging computer program and a tracking computer program embodied in the computer readable medium for specifying status data for retrieval from the messaging queues, receiving the status data from the messaging queues into a tracking queue, and storing the status data in a data storage system.
摘要:
A method for providing atomicity for a unit of work involving a plurality of participants, the method comprising the steps of: sending a prepare request to at least one participant, wherein the request comprises data required for recovery prurposes of the unit of work; and on recovery of the unit of work, recovering the unit of work comprising: obtaining the data from the at least one participant; and using the obtained data to recover and preserve the atomicity of the unit of work.