Package coilmq :: Module scheduler :: Class SubscriberPriorityScheduler

Class SubscriberPriorityScheduler

object --+
         |
        SubscriberPriorityScheduler

Abstract base class for choosing which recipient (subscriber) should receive a message.

Instance Methods

coilmq.server.StompConnection

choice(self, subscribers, message)
Chooses which subscriber (from list) should recieve specified message.

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

Class Variables
	__metaclass__ = `abc.ABCMeta`

Properties
Inherited from `object`: `__class__`

Method Details

choice(self, subscribers, message)

Chooses which subscriber (from list) should recieve specified message.

Parameters:

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

Returns: coilmq.server.StompConnection

A selected subscriber from the list or None if no subscriber could be chosen (e.g. list is empty).

Decorators:

@abc.abstractmethod