Package coilmq :: Module scheduler :: Class RandomSubscriberScheduler

Class RandomSubscriberScheduler

                 object --+    
                          |    
SubscriberPriorityScheduler --+
                              |
                             RandomSubscriberScheduler

A delivery scheduler that chooses a random subscriber for message recipient.

Instance Methods

coilmq.server.StompConnection

choice(self, subscribers, message)
Chooses a random connection from subscribers 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)

Chooses a random connection from subscribers 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