Abstract:
Access to a device is controlled in a data processing network by receiving a first request from a client to connect to a device where the device is limited to a fixed number of client connections and connecting the client to an available client connection of the device if the fixed number of client connections on the device would not be exceeded by connecting the client. Access is further controlled by testing liveness of a current client connection on the device if the fixed number of client connections on the device would be exceeded by connecting the client and dropping the current client connection if the liveness testing indicates that the current client connection is not live.
Abstract:
Access to a device is controlled in a data processing network by receiving a first request from a client to connect to a device where the device is limited to a fixed number of client connections and connecting the client to an available client connection of the device if the fixed number of client connections on the device would not be exceeded by connecting the client. Access is further controlled by testing liveness of a current client connection on the device if the fixed number of client connections on the device would be exceeded by connecting the client and dropping the current client connection if the liveness testing indicates that the current client connection is not live.
Abstract:
A method and system of controlling access to a destination (17, 23, 24) in a data processing network where the destination is limited to a fixed number of requesters responds to a new request (50) for access from a given requestor (20) by determining whether the fixed number would be exceeded. If the fixed number would not be exceeded (51), the new request is granted by connecting (52) the given requester to the destination. If the fixed number would be exceeded, the liveness of the or each current connection to a respective requester is tested (55). If the liveness test succeeds, the new request is rejected but if the liveness test fails, the new request is granted (52).
Abstract:
A method and system of controlling access to a destination (17, 23, 24) in a data processing network where the destination is limited to a fixed number of requesters responds to a new request (50) for access from a given requestor (20) by determining whether the fixed number would be exceeded. If the fixed number would not be exceeded (51), the new request is granted by connecting (52) the given requester to the destination. If the fixed number would be exceeded, the liveness of the or each current connection to a respective requester is tested (55). If the liveness test succeeds, the new request is rejected but if the liveness test fails, the new request is granted (52).
Abstract:
A method, system, and computer program for delivering messages and data to competing consumers. One aspect of the invention includes a message delivery system including a destination messaging engine, one or more receiver messaging engines, and a message pool. The destination messaging engine is configured to distribute data from one or more producers. The receiver messaging engines are configured to request data from the destination messaging engine and transmit the data to one or more consumers. The message pool is configured to store data from the producers, with the destination messaging engine arbitrating data in the message pool among the receiver messaging engines.
Abstract:
A method of routing messages to multiple consumers comprises determining a probability function defining message classification probabilities for each of a plurality of consumer sets, receiving a plurality of messages, classifying each message, storing each message in a queue, receiving notification of a consumer available to process a message, ascertaining the consumer set to which the available consumer belongs, accessing the probabilities for the ascertained consumer set, selecting a message classification according to the accessed probabilities, and transmitting a message, of the selected classification, to the available consumer.
Abstract:
A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.
Abstract:
There is disclosed a source messaging system having a queue for receiving messages. The source messaging system has means for determining whether a message should be permitted to become INDOUBT. This is done by retrieving a value denoting the maximum number of messages that may be permitted to become INDOUBT at any one time; determining whether the message falls within the range denoted by the value; and responsive to determining that the message falls within the range, permitting the message to become INDOUBT.
Abstract:
There is disclosed a method, apparatus and computer program for an application instance to request attachment to a queue partition on a messaging server within a plurality of messaging servers, each messaging server holding at least one queue partition, the set of queue partitions together forming a single queue. An application instance requests attachment to a queue partition, the request requesting exclusivity with regard to other application instances having a common identifier. Responsive to an indicating that the request has been successful, the application instance interacts with the queue partition.
Abstract:
Requests from a client to put messages into an input queue are intercepted before reaching the input queue. The intercepted requests which refer to a message destined for the server application are established. Information associated with the server application indicates that the server application will process such a message according to a predetermined manner. A request associated with the server application for retrieving such a message is transactional, and the server application uses a one-phase commit for retrieving such a message. Such a message can then be matched with the server application's request such that the server application can retrieve the message. In this way, such messages by-pass the input queue, and are, therefore, not logged, resulting in a reduction of I/O.