Publish and subscribe data processing apparatus, method and computer program product with declaration of a unique publisher broker

    公开(公告)号:GB2345157B

    公开(公告)日:2003-06-18

    申请号:GB9828278

    申请日:1998-12-23

    Applicant: IBM

    Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker data processing apparatus has: a unit for receiving a data message published on a first topic by a first publisher application; and a unit for forwarding the received published data message to a subscriber application which has requested, by entering subscription data, to receive a message on the first topic; wherein the first broker data processing apparatus sends a declaration to at least one other broker data processing apparatus of said plurality of broker data processing apparatuses declaring that the first broker data processing apparatus is the only broker data processing apparatus that is directly communicating with a publisher application that is publishing on the first topic.

    Method, apparatus and computer program product for eliminating expired messages from a queue in a data processing system

    公开(公告)号:GB2329986B

    公开(公告)日:2002-07-10

    申请号:GB9720999

    申请日:1997-10-04

    Applicant: IBM

    Abstract: A data processing apparatus runs a messaging and queuing software package whereby messages received at the data processing apparatus are stored in a message queue. The apparatus has: a processor; a high storage capacity storage device; and a low storage capacity storage device (e.g., a high-speed cache); the high storage capacity storage device stores full-length expiration data for each message in the message queue; and the low storage capacity storage device stores an abbreviated version of the full-length expiration data for each message in the message queue, the abbreviated version used to quickly and efficiently determine whether a queued message is expired.

    Efficient data conversion of list of strings

    公开(公告)号:GB2343024A

    公开(公告)日:2000-04-26

    申请号:GB9823007

    申请日:1998-10-22

    Applicant: IBM

    Abstract: A method of converting a plurality of strings stored in an input buffer to a plurality of evenly spaced strings in an output buffer involves first passing over the input buffer and, for each string, placing the string in the output buffer at a next available address. If the string length is longer than a maximum string length, the maximum string length is set to the string length and the string is set as the last incorrectly placed string in the output buffer. The next available address in the output buffer is incremented by the maximum string length plus the product of any positive difference between the current string length and previous maximum string length and the number of strings already placed in the output buffer. A second pass over the output buffer from the last incorrectly placed string in a direction opposite the first passing step moves each string within the output buffer to an address being a multiple of the maximum string length from the start of the output buffer.

    Access control for groups of related data items

    公开(公告)号:GB2330220B

    公开(公告)日:2002-04-10

    申请号:GB9721141

    申请日:1997-10-07

    Applicant: IBM

    Abstract: Access to groups of related items which are accessible by multiple processes in a computer system is controlled, in response to determining that an individually accessed data item is part of a group, by marking the whole group as locked and returning an unlocking key to the process accessing the original data item. Further access to any items of the group by a process is prevented except on provision of the key. The invention is particularly applicable to messages in a message queuing system which are logically grouped and yet may be individually destructively retrieved.

    Access control for groups of related data items

    公开(公告)号:GB2330220A

    公开(公告)日:1999-04-14

    申请号:GB9721141

    申请日:1997-10-07

    Applicant: IBM

    Abstract: Access to groups of related items which are accessible by multiple processes in a computer system is controlled, in response to determining 106 that an individually accessed data item is part of a group, by storing 107 the message sequence number as a locking key in the group lock key field (77 Figure 7), and setting 108 the group locked flag bit to complete the group locking process. Further access by a process to any items of a group for which the group locked flag is set is denied unless the message sequence number held in the browse cursor key field matches (207, Figure 9) the group locked key. The system is particularly applicable to a messaging and queuing system in which messages are logically grouped and yet may be individually destructively retrieved.

    Publish and subscribe data processing with subscriber option to request subscription propagation prior to acknowledgment

    公开(公告)号:GB2345164A

    公开(公告)日:2000-06-28

    申请号:GB9828762

    申请日:1998-12-24

    Applicant: IBM

    Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker apparatus 111 has: a software unit for receiving subscription data from a subscriber application 301; a software unit for providing an acknowledgement to the subscriber application to acknowledge that the subscription data has been received; a software unit for propagating the subscription data to a group of other broker apparatuses; a software unit for determining whether the means for propagating has propagated the subscription data to the group of other broker apparatuses; and a software unit for receiving an indication from the subscriber application that the acknowledgement should not be sent to the subscriber application until the means for determining has determined that the means for propagating has propagated the subscription data to the group of other broker apparatuses.

    Publish and subscribe data processing with declaration of a unique publisher broker

    公开(公告)号:GB2345157A

    公开(公告)日:2000-06-28

    申请号:GB9828278

    申请日:1998-12-23

    Applicant: IBM

    Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker data processing apparatus 12 has:a unit for receiving a data message published on a first topic by a first publisher application 201 and a unit for forwarding the received published data message to a subscriber application 203 which has requested, by entering subscription data, to receive a message on the first topic; wherein the first broker data processing apparatus sends a declaration to at least one other of the broker data processing apparatuses declaring that the first broker data processing apparatus is the only broker data processing apparatus that is directly communicating with a publisher application that is publishing on the first topic.

    system for eliminating time-expired messages from a message queue in a data processing system

    公开(公告)号:GB2329986A

    公开(公告)日:1999-04-07

    申请号:GB9720999

    申请日:1997-10-04

    Applicant: IBM

    Abstract: A data processing apparatus runs a messaging and queuing software package whereby a newly-received message is added to a queue (11, Figure1). Associated data including 96-bit message time expiry data are stored in a high storage-capacity long-term storage hard disk drive device (14). An abbreviated version (24 bits) of the message time expiry data is stored in a low storage capacity high-speed cache memory device (12). When retrieval of a specific message from the queue is requested, the version stored in cache of the expiry data for each, or for alternate ones, of the messages stored in the queue is compared 32 with the current date and time in 24-bit format. Any message of which the 24-bit expiry data are of a value equal to, or less than, the current date and time, is deleted 33 from the message queue. Then the specific message requested is retrieved 34 from the message queue, and a full one-millisecond (96-bit) expiry data check is made 35, to determine whether this message has become time-expired in the last four minutes. In this way, long-expired messages (ie those that have been expired by at least four minutes) are discarded more efficiently than in the prior art.

Patent Agency Ranking