International Business Machines Corporation

Brian Clive Homewood

Andrew Ian Hickson

David Ware

Adrian David Dick

John Michael Knapman

Steven William Bolam

Craig H Stirling

Nicholas David Butler

Steven P Larky

Christopher Matthewson

Gavin David Beardall

Andrew David Banks

Roderick M West

Tristram Terence Reilly

Paolo G Sidoli

Malcolm Douglas Buttimer

A method, system, and computer program product that includes a processor assigning a network connection to an application, based upon the application requesting the network connection from a pool of network connections for connecting applications to a network resource, the assigned network connection for communicating a message with the network resource. The processor replaces the assigned network connection in the pool with a placeholder comprising configuration data of the assigned connection. The processor determined a period of inactivity of the assigned network connection, and the processor returns the assigned network connection to the pool, based upon the period reaching a defined threshold of inactivity.

Connection pool management

A method and computer program product is disclosed for managing a message broker and subscriber application programs in a publish/subscribe messaging system so as to maintain the state of the subscriber application program on the broker subscriber application program.

Managing a message subscription in a publish/subscribe messaging system

A system and method for messaging in which, when a connection to a queue manager () is established, the queue manager allocates a Connection Identifier from the same name space () as Message Identifiers and returns this information () to the user. The user can then use this Connection Identifier as a Correlation Identifier, safe in the knowledge that it will not clash with any system generated Message Identifier or Correlation Identifier. A secondary benefit to this allocation scheme is that if a shared reply queue suffers from a build-up of messages then the Correlation Identifier in those messages can be used to identify the application expected to receive those messages.

System and method for messaging

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.

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

A publishing data processing method for use 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 directly from a subscriber application, the method includes steps of: Publishing a message on a topic to a first broker data processing apparatus; and providing an indication as to whether the published data message is to be considered as local to the first broker apparatus. Also included are an analogous subscribing data processing method, an analogous broker data processing method, apparatuses and computer program products.

Publish and subscribe data processing with ability to specify a local publication/subscription

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 has: a software unit for receiving via said input subscription data from a subscriber application; a software unit for providing an acknowledgement to said subscriber application to acknowledge that the subscription data has been received; a software unit for propagating said subscription data to a group of other broker apparatuses; a software unit for determining whether said means for propagating has propagated said subscription data to the group of other broker apparatuses; and a software unit for receiving via said input an indication from said subscriber application that said acknowledgement should not be sent to the subscriber application until the means for determining has determined that said means for propagating has propagated said subscription data to the group of other broker apparatuses.

Publish and subscribe data processing with subscriber option to request

In a logic circuit having clocked state latches and combinatorial logic for functional processing of a task in response to functional clocking of the state latches, the state latches are additionally interconnected to form a scannable chain of latches, and task switching logic is provided for suspending task processing by interrupting the functional clocking of the state latches and, during such suspension, scanning the state latches such that existing contents of the state latches defining a task state can be saved from the state latches or new contents defining a task state can be loaded into the state latches. The invention provides an efficient means for switching tasks being performed by a logic circuit in a multiprocessing enviornment.

Logic circuit for task processing

Apparatus for serializing 2.sup.M parallel outputs of an all points addressable memory into successive data groups, with each data group corresponding to a respective value for a pixel in an image, wherein the bit-length of the pixel value is selectable. The apparatus includes a gate circuit having 2.sup.M parallel input junctions connected to the outputs of the memory and 2.sup.N output junctions. The gate circuit selectively converts each set of 2.sup.M parallel inputs at the input junctions in to 2.sup.M-n successive data groups, with each group having a bit-length of 2.sup.n bits. Each such group is transmitted to 2.sup.n of the 2.sup.N output junctions. A communication element conveys to the gate circuit a signal which controls the bit-length 2.sup.n of the data groups, wherein n is an integer 1.ltoreq.n.ltoreq.N.ltoreq.M.

Growing community of inventors

Winchester, United Kingdom

Brian Clive Homewood