Package coilmq :: Module scheduler :: Class FavorReliableSubscriberScheduler

Class FavorReliableSubscriberScheduler

                 object --+    
                          |    
SubscriberPriorityScheduler --+
                              |
                             FavorReliableSubscriberScheduler

A random delivery scheduler which prefers reliable subscribers.

Instance Methods

coilmq.server.StompConnection

choice(self, subscribers, message)
Choose a random connection, favoring those that are reliable from subscriber pool to deliver specified message.

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __init__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Variables
Inherited from `SubscriberPriorityScheduler`: `__metaclass__`

Properties
Inherited from `object`: `__class__`

Method Details

choice(self, subscribers, message)

Choose a random connection, favoring those that are reliable from subscriber pool to deliver specified message.

Parameters:

subscribers (list of coilmq.server.StompConnection) - Collection of subscribed connections to destination.
message (stompclient.frame.Frame) - The message to be delivered.

Returns: coilmq.server.StompConnection

A random subscriber from the list or None if list is empty.

Overrides: SubscriberPriorityScheduler.choice