Index

_

__del__() (django_message_broker.server.utils.WaitFor method) __getitem__() (django_message_broker.server.data_message.DataMessage method) (django_message_broker.server.signalling_message.SignallingMessage method) __next__() (django_message_broker.server.server_queue.RoundRobinDict method) __repr__() (django_message_broker.server.data_message.DataMessage method) (django_message_broker.server.signalling_message.SignallingMessage method) __setitem__() (django_message_broker.server.data_message.DataMessage method) (django_message_broker.server.signalling_message.SignallingMessage method) _await_data_response() (django_message_broker.server.channels_client.ChannelsClient method) _await_signalling_response() (django_message_broker.server.channels_client.ChannelsClient method) _callback() (django_message_broker.server.utils.WaitFor method) _data_task_complete() (django_message_broker.server.channels_client.ChannelsClient method) _data_task_exception() (django_message_broker.server.channels_client.ChannelsClient method) _delivery() (django_message_broker.server.channels_client.ChannelsClient method) _flush_all() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _flush_groups() (django_message_broker.server.channels_server.ChannelsServer method) _flush_messages() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.client_queue.ClientQueue method) (django_message_broker.server.server_queue.ChannelQueue method) _flush_queues() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _flush_subscribers() (django_message_broker.server.server_queue.ChannelQueue method)

_group_add() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _group_discard() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _print() (django_message_broker.server.channels_server.ChannelsServer method) _receive() (django_message_broker.server.channels_client.ChannelsClient method) _receive_data() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _receive_signalling() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _run() (django_message_broker.server.utils.WeakPeriodicCallback method) _send() (django_message_broker.server.channels_client.ChannelsClient method) _send_to_channel() (django_message_broker.server.channels_server.ChannelsServer method) _send_to_group() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _set_messages_available() (django_message_broker.server.client_queue.ClientQueue method) (django_message_broker.server.server_queue.ChannelQueue method) _set_subscribers_available() (django_message_broker.server.server_queue.ChannelQueue method) _signalling_task_complete() (django_message_broker.server.channels_client.ChannelsClient method) _signalling_task_exception() (django_message_broker.server.channels_client.ChannelsClient method) _subscribe() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) _unsubscribe() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method)

A

all_events() (django_message_broker.server.utils.WaitFor method)

C

can_be_flushed (django_message_broker.server.client_queue.ClientQueue property) ChannelFlushed ChannelQueue (class in django_message_broker.server.server_queue) ChannelQueueFull channels (django_message_broker.layer.ChannelsServerLayer property) ChannelsClient (class in django_message_broker.server.channels_client) ChannelsClient.DataCommands (class in django_message_broker.server.channels_client) ChannelsClient.SignallingCommands (class in django_message_broker.server.channels_client) ChannelsServer (class in django_message_broker.server.channels_server)

ChannelsServer.DataCommands (class in django_message_broker.server.channels_server) ChannelsServer.SignallingCommands (class in django_message_broker.server.channels_server) ChannelsServerError ChannelsServerLayer (class in django_message_broker.layer) ChannelsSocketClosed clear_receive_callback() (django_message_broker.server.socket_manager.SocketManager method) ClientQueue (class in django_message_broker.server.client_queue) clients_waiting (django_message_broker.server.client_queue.ClientQueue property) close() (django_message_broker.layer.ChannelsServerLayer method) copy() (django_message_broker.server.data_message.DataMessage method)

D

DataMessage (class in django_message_broker.server.data_message) DataMessageCommands (class in django_message_broker.server.data_message) dealer (django_message_broker.server.server_queue.Endpoint attribute) discard() (django_message_broker.server.server_queue.ChannelQueue method) django_message_broker.layer module django_message_broker.process_client module django_message_broker.server.channels_client module django_message_broker.server.channels_server module django_message_broker.server.client_queue module

django_message_broker.server.data_message module django_message_broker.server.exceptions module django_message_broker.server.server_queue module django_message_broker.server.signalling_message module django_message_broker.server.socket_manager module django_message_broker.server.utils module

E

Endpoint (class in django_message_broker.server.server_queue)

event_loop() (django_message_broker.server.server_queue.ChannelQueue method) expiry (django_message_broker.server.server_queue.Endpoint attribute)

F

first_key() (django_message_broker.server.server_queue.RoundRobinDict method) flush() (django_message_broker.layer.ChannelsServerLayer method)

from_msg() (django_message_broker.server.data_message.DataMessage class method) (django_message_broker.server.signalling_message.SignallingMessage class method)

G

get() (django_message_broker.server.data_message.DataMessage method) (django_message_broker.server.signalling_message.SignallingMessage method) get_body() (django_message_broker.server.data_message.DataMessage method) get_bound_callables() (django_message_broker.server.utils.MethodRegistry class method) get_routing_id() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.socket_manager.SocketManager method) get_socket() (django_message_broker.server.socket_manager.SocketManager method)

get_stream() (django_message_broker.server.socket_manager.SocketManager method) get_subscriber_id() (django_message_broker.server.channels_client.ChannelsClient method) group_add() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method) group_discard() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method) group_send() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method)

I

id (django_message_broker.server.server_queue.Endpoint property) IntegerSequence (class in django_message_broker.server.utils)

is_empty (django_message_broker.server.client_queue.ClientQueue property) is_empty() (django_message_broker.server.server_queue.ChannelQueue method) is_process_channel (django_message_broker.server.server_queue.Endpoint attribute)

M

MessageCommandUnknown MessageFormatException MessageTooLarge MethodProxy (class in django_message_broker.server.utils) MethodRegistry (class in django_message_broker.server.utils) module django_message_broker.layer django_message_broker.process_client django_message_broker.server.channels_client django_message_broker.server.channels_server django_message_broker.server.client_queue django_message_broker.server.data_message django_message_broker.server.exceptions django_message_broker.server.server_queue django_message_broker.server.signalling_message django_message_broker.server.socket_manager django_message_broker.server.utils

N

new_channel() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method)

new_iterator() (django_message_broker.server.utils.IntegerSequence method)

O

one_event() (django_message_broker.server.utils.WaitFor method)

P

ProcessClient (class in django_message_broker.process_client) pull() (django_message_broker.server.client_queue.ClientQueue method)

pull_and_send() (django_message_broker.server.server_queue.ChannelQueue method) push() (django_message_broker.server.client_queue.ClientQueue method) (django_message_broker.server.server_queue.ChannelQueue method)

Q

quick_copy() (django_message_broker.server.data_message.DataMessage method)

R

receive() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method) recv() (django_message_broker.server.data_message.DataMessage class method) (django_message_broker.server.signalling_message.SignallingMessage class method)

register() (django_message_broker.server.utils.MethodProxy class method) (django_message_broker.server.utils.MethodRegistry class method) RoundRobinDict (class in django_message_broker.server.server_queue)

S

send() (django_message_broker.layer.ChannelsServerLayer method) (django_message_broker.process_client.ProcessClient method) (django_message_broker.server.data_message.DataMessage method) (django_message_broker.server.signalling_message.SignallingMessage method) set_receive_callback() (django_message_broker.server.socket_manager.SocketManager method) SignallingMessage (class in django_message_broker.server.signalling_message) SignallingMessageCommands (class in django_message_broker.server.signalling_message) socket (django_message_broker.server.server_queue.Endpoint attribute) SocketManager (class in django_message_broker.server.socket_manager)

start() (django_message_broker.server.channels_server.ChannelsServer method) (django_message_broker.server.socket_manager.SocketManager method) stop() (django_message_broker.server.channels_client.ChannelsClient method) (django_message_broker.server.channels_server.ChannelsServer method) (django_message_broker.server.client_queue.ClientQueue method) (django_message_broker.server.server_queue.ChannelQueue method) (django_message_broker.server.socket_manager.SocketManager method) subscribe() (django_message_broker.server.server_queue.ChannelQueue method) SubscriptionError

T

time_to_live (django_message_broker.server.server_queue.Endpoint attribute)

U

unregister() (django_message_broker.server.utils.MethodProxy class method)

W

WaitFor (class in django_message_broker.server.utils)

WeakPeriodicCallback (class in django_message_broker.server.utils)