-
公开(公告)号:GB2345157B
公开(公告)日:2003-06-18
申请号:GB9828278
申请日:1998-12-23
Applicant: IBM
Inventor: BOLAM STEVEN WILLIAM , HOMEWOOD BRIAN CLIVE , HICKSON ANDREW , KNAPMAN JOHN MICHAEL , WARE DAVID
IPC: G06F15/16 , G06F15/173 , G06F17/30 , G06Q40/00
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.
-
2.
公开(公告)号:GB2345158A
公开(公告)日:2000-06-28
申请号:GB9828279
申请日:1998-12-23
Applicant: IBM
Inventor: BOLAM STEVEN WILLIAM , HOMEWOOD BRIAN CLIVE , HICKSON ANDREW , KNAPMAN JOHN MICHAEL , WARE DAVID
Abstract: In a publish/subscribe system comprising a network of broker data processors each of which can receive a published message directly from a publisher application 201 and/or receive subscription data directly from a subscriber application 204, an indication is provided as to whether the published message and/or the subscription data is to be considered as local to a particular broker data processor. The indication may be included in the message or subscription data and used to determine whether or not the message/data should be forwarded to others of the broker data processors.
-
公开(公告)号:GB2329986B
公开(公告)日:2002-07-10
申请号:GB9720999
申请日:1997-10-04
Applicant: IBM
Inventor: HICKSON ANDREW , WILKINSON JAMES GORDON
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.
-
公开(公告)号:GB2343024A
公开(公告)日:2000-04-26
申请号:GB9823007
申请日:1998-10-22
Applicant: IBM
Inventor: DYCHE MARK , HICKSON ANDREW
IPC: G06F17/22
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.
-
公开(公告)号:GB2330220B
公开(公告)日:2002-04-10
申请号:GB9721141
申请日:1997-10-07
Applicant: IBM
Inventor: HICKSON ANDREW , WILKINSON JAMES GORDON
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.
-
公开(公告)号:GB2330220A
公开(公告)日:1999-04-14
申请号:GB9721141
申请日:1997-10-07
Applicant: IBM
Inventor: HICKSON ANDREW , WILKINSON JAMES GORDON
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.
-
公开(公告)号:GB2345164A
公开(公告)日:2000-06-28
申请号:GB9828762
申请日:1998-12-24
Applicant: IBM
Inventor: BOLAM STEVEN WILLIAM , HOMEWOOD BRIAN CLIVE , HICKSON ANDREW , KNAPMAN JOHN MICHAEL , WARE DAVID
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.
-
公开(公告)号:GB2345157A
公开(公告)日:2000-06-28
申请号:GB9828278
申请日:1998-12-23
Applicant: IBM
Inventor: BOLAM STEVEN WILLIAM , HOMEWOOD BRIAN CLIVE , HICKSON ANDREW , KNAPMAN JOHN MICHAEL , WARE DAVID
IPC: G06F15/16 , G06F15/173 , G06F17/30 , G06Q40/00
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.
-
9.
公开(公告)号:GB2329986A
公开(公告)日:1999-04-07
申请号:GB9720999
申请日:1997-10-04
Applicant: IBM
Inventor: HICKSON ANDREW , WILKINSON JAMES GORDON
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.
-
-
-
-
-
-
-
-