公开(公告)号：JP2000090058A

公开(公告)日：2000-03-31

申请号：JP15941799

申请日：1999-06-07

Applicant: IBM

Inventor： HASTINGS ANDREW BLAIR ,  RAMASWAMY SHANKAR ,  SCHMITZ DONALD EDWIN ,  WANG QINHUA ,  YOUNG MICHAEL WAYNE

IPC: G06F15/16 ,  G06F9/46 ,  G06F13/00 ,  G06F17/30

Abstract: PROBLEM TO BE SOLVED: To efficiently use usable resources by allowing a distributing means to make a reservation by a publication-side distribution agent data processing unit and perform reception by a subscription-side distribution agent data processing unit or a subscriber application. SOLUTION: When a publisher 11 publishes a stock market message to a stream stock, the publisher 11 generates an RPC(remote procedure) call to the route distribution agent 21 of the highest level of broker tree structure. By this RPC call, a subscription request for the stream stock by a subscriber 32 is shown through the leaflet distribution agent of the lowest level. Namely, the data message of the publisher 11 is transmitted to the subscriber 32 through a downstream route distribution agent 21, and then an arbitrary intermediate distribution agent 22 and a leaflet distribution agent 24.

公开(公告)号：JP2000222297A

公开(公告)日：2000-08-11

申请号：JP13086499

申请日：1999-05-12

Applicant: IBM

Inventor： HASTINGS ANDREW BLAIR ,  RAMASWAMY SHANKAR ,  SCHMITZ DONALD EDWIN ,  WANG QINHUA ,  YOUNG MICHAEL WAYNE

IPC: G06F15/177 ,  G06F9/46 ,  G06F13/00 ,  G06F15/16 ,  G06F17/00 ,  H04L29/06

Abstract: PROBLEM TO BE SOLVED: To provide a device and a method for transmitting new constitution data from a system manager to each distribution agent in a broker with the minimum effort on the side of system manager and to provide a program product. SOLUTION: An issue and read data processing broker device 2 is provided with a means for receiving a data message issued on a theme specification stream from an issuer application corresponding to this issuer application and a means for distributing the received issue data message to reader applications 31-34 requesting the reception of the message on the stream of issuing the issue message and one of streams is secured for a managing message for describing the constitution change of the broker device.

公开(公告)号：CA2267478C

公开(公告)日：2003-02-04

申请号：CA2267478

申请日：1999-03-30

Applicant: IBM

Inventor： RAMASWAMY SHANKAR ,  YOUNG MICHAEL WAYNE ,  SCHMITZ DONALD EDWIN ,  HASTINGS ANDREW BLAIR ,  WANG QINHUA

IPC: G06F15/16 ,  G06F9/46 ,  G06F13/00 ,  G06F17/30 ,  G06F19/00

Abstract: A publish/subscribe data processing broker apparatus has: a means for receiving from a publisher application data messages published on a subject-specific stream b y the publisher application; and a means for distributing the received published data messag es to a subscriber application which has requested to receive messages on the stream upon which the published messages were published, the means for distributing including a plurality of connected distribution agent data processing units; wherein one of the streams is reserved for messages published by a publishing distribution agent data processing unit and intended for receipt by a subscribing distribution agent data processing unit located adjacent the publishing distribution agent data processing unit or intended for receipt by a subscriber application located adjacent the publishing distribution agent data processing unit.

公开(公告)号：CA2267478A1

公开(公告)日：1999-12-25

申请号：CA2267478

申请日：1999-03-30

Applicant: IBM

Inventor： HASTINGS ANDREW BLAIR ,  WANG QINHUA ,  SCHMITZ DONALD EDWIN ,  YOUNG MICHAEL WAYNE ,  RAMASWAMY SHANKAR

IPC: G06F15/16 ,  G06F9/46 ,  G06F13/00 ,  G06F17/30 ,  G06F19/00

Abstract: A publish/subscribe data processing broker apparatus has: a means for receiving from a publisher application data messages published on a subject-specific stream by the publisher application; and a means for distributing the received published data messages to a subscriber application which has requested to receive messages on the stream upon which the published messages were published, the means for distributing including a plurality of connected distribution agent data processing units; wherein one of the streams is reserved for messages published by a publishing distribution agent data processing unit and intended for receipt by a subscribing distribution agent data processing unit located adjacent the publishing distribution agent data processing unit or intended for receipt by a subscriber application located adjacent the publishing distribution agent data processing unit.