Patent ID: 8392555

Claim:
A messaging system for controlling message throughput rates of publisher clients connectable to a broker device in a publish/subscribe network, the broker device operable to handle a matching of publications with subscriptions and operable to handle a distribution of the publications to the subscriber clients comprising: a memory device; a processor coupled to said memory device, said processor configured to: determine an allocation of the broker device's message throughput for each publisher client, the allocation being determined based on a ratio between message-producing rates of the publisher clients; update the determined allocation according to changes in the message-producing rates of the publisher clients; receive each publisher client's updated allocation and gather statistics of the message- producing rates of the publisher clients and a message-consuming rate of each subscriber client connected to the broker device, wherein if a first message-producing rate of a first publisher client exceeds the updated allocation of the first publisher client, messages produced by the first publisher client are not accepted at the broker device and a first message is sent to the first publisher client to throttle the first message-producing rate of the first publisher client, said processor further configured to: receive, at the second publisher client, an acceptable message throughput from the broker device; adjust, by the second publisher client, the expected message throughput according to the received acceptable message throughput; and re-attempt, by the second publisher client, to establish the connection with the broker device.