Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

abort() (in StompEngine)	allow_reuse_address (in TestStompServer)	authenticate() (in MockAuthenticator)
ack() (in StompEngine)	assertErrorFrame() (in EngineTest)	Authenticator (in coilmq.auth)
ack() (in QueueManager)	auth (in coilmq)	AuthError (in coilmq.exception)
ack() (in MockQueueManager)	authenticate() (in Authenticator)
allow_reuse_address (in StompServer)	authenticate() (in SimpleAuthenticator)

B

BaseFunctionalTestCase (in coilmq.tests.functional)	BasicTest (in coilmq.tests.functional.test_basic)
BasicSqlAlchemyStoreTest (in coilmq.tests.functional.test_basic_sa)	begin() (in StompEngine)

C

choice() (in FavorReliableSubscriberScheduler)	close() (in QueueStore)	concurrency (in coilmq.util)
choice() (in QueuePriorityScheduler)	close() (in QueueStore)	config (in coilmq)
choice() (in RandomQueueScheduler)	close() (in DbmQueue)	config (in coilmq.config)
choice() (in RandomSubscriberScheduler)	close() (in SAQueue)	ConfigError (in coilmq.exception)
choice() (in SubscriberPriorityScheduler)	close() (in TestStompClient)	connect() (in StompEngine)
clear_transaction_frames() (in QueueManager)	close() (in TopicManager)	connect() (in TestStompClient)
clear_transaction_frames() (in MockQueueManager)	coilmq	context_serve() (in coilmq.start)
ClientDisconnected (in coilmq.exception)	commit() (in StompEngine)
close() (in QueueManager)	CommonQueueTestsMixin (in coilmq.tests.store)

D

daemon_support (in coilmq.start)	dequeue() (in DbmQueue)	destinations() (in SAQueue)
dbm (in coilmq.store)	dequeue() (in MemoryQueue)	disconnect() (in StompEngine)
DbmQueue (in coilmq.store.dbm)	dequeue() (in SAQueue)	disconnect() (in QueueManager)
DBMQueueManagerTest (in coilmq.tests.test_queue_dbm)	destinations() (in QueueStore)	disconnect() (in TestStompClient)
DbmQueueTest (in coilmq.tests.store.test_dbm)	destinations() (in DbmQueue)	disconnect() (in TopicManager)
dequeue() (in QueueStore)	destinations() (in MemoryQueue)	DurableTopicStore (in coilmq.store)

E

engine (in coilmq)	enqueue() (in QueueStore)	enqueue() (in SAQueue)
engine (in coilmq.store.sa.meta)	enqueue() (in DbmQueue)	exception (in coilmq)
EngineTest (in coilmq.tests.test_engine)	enqueue() (in MemoryQueue)

F

FavorReliableSubscriberScheduler (in coilmq.scheduler)	frames() (in QueueStore)	functional (in coilmq.tests)
finish() (in StompRequestHandler)	frames_table (in coilmq.store.sa.model)
frames() (in QueueStore)	from_configfile() (in SimpleAuthenticator)

H

handle() (in StompRequestHandler)	has_frames() (in DbmQueue)	has_frames() (in SAQueue)
has_frames() (in QueueStore)	has_frames() (in MemoryQueue)

I

init_config() (in coilmq.config)	init_logging() (in coilmq.config)	init_model() (in coilmq.store.sa)

L

logger (in coilmq.start)	LOGIN (in MockAuthenticator)

M

main() (in coilmq.start)	MemoryQueue (in coilmq.store.memory)	MockAuthenticator (in coilmq.tests.mock)
make_dbm() (in coilmq.store.dbm)	MemoryQueueTest (in coilmq.tests.store.test_memory)	MockConnection (in coilmq.tests.mock)
make_sa() (in coilmq.store.sa)	meta (in coilmq.store.sa)	MockQueueManager (in coilmq.tests.mock)
make_simple() (in coilmq.auth.simple)	metadata (in coilmq.store.sa.meta)	MockTopicManager (in coilmq.tests.mock)
memory (in coilmq.store)	mock (in coilmq.tests)	model (in coilmq.store.sa)

N

next() (in QueueFrameIterator)

P

PASSCODE (in MockAuthenticator)	process_frame() (in StompEngine)	ProtocolError (in coilmq.exception)

Q

queue (in coilmq)	QueueManager (in coilmq.queue)	QueueStore (in coilmq.store)
QueueDeliverySchedulerTest (in coilmq.tests.test_scheduler)	QueueManagerTest (in coilmq.tests.test_queue)
QueueFrameIterator (in coilmq.store)	QueuePriorityScheduler (in coilmq.scheduler)

R

S

sa (in coilmq.store)	server_activate() (in TestStompServer)	size() (in QueueStore)
SAQueue (in coilmq.store.sa)	server_close() (in StompServer)	size() (in DbmQueue)
SAQueueManagerTest (in coilmq.tests.test_queue_sa)	server_close() (in StompServer)	size() (in MemoryQueue)
SAQueueTest (in coilmq.tests.store.test_sa)	server_from_config() (in coilmq.start)	size() (in SAQueue)
scheduler (in coilmq)	Session (in coilmq.store.sa.meta)	socketserver (in coilmq.server)
send() (in StompEngine)	setup() (in StompRequestHandler)	start (in coilmq)
send() (in QueueManager)	setUp() (in BaseFunctionalTestCase)	StompConnection (in coilmq.server)
send() (in TestStompClient)	setUp() (in BaseFunctionalTestCase)	StompEngine (in coilmq.engine)
send() (in MockQueueManager)	setUp() (in DbmQueueTest)	StompRequestHandler (in coilmq.server.socketserver)
send() (in MockTopicManager)	setUp() (in MemoryQueueTest)	StompServer (in coilmq.server.socketserver)
send() (in TopicManager)	setUp() (in SAQueueTest)	store (in coilmq)
send_frame() (in StompConnection)	setUp() (in SimpleAuthenticatorTest)	store (in coilmq.tests)
send_frame() (in StompRequestHandler)	setUp() (in EngineTest)	subscribe() (in StompEngine)
send_frame() (in TestStompClient)	setUp() (in QueueManagerTest)	subscribe() (in QueueManager)
send_frame() (in MockConnection)	setUp() (in QueueManagerTest)	subscribe() (in TestStompClient)
send_simple() (in QueueManagerTest)	setUp() (in TopicManagerTest)	subscribe() (in MockQueueManager)
send_simple() (in QueueManagerTest)	shutdown() (in StompServer)	subscribe() (in MockTopicManager)
send_simple() (in TopicManagerTest)	shutdown() (in StompServer)	subscribe() (in TopicManager)
serve_forever() (in StompServer)	simple (in coilmq.auth)	subscriber_count() (in QueueManager)
serve_forever() (in StompServer)	SimpleAuthenticator (in coilmq.auth.simple)	SubscriberPriorityScheduler (in coilmq.scheduler)
server (in coilmq)	SimpleAuthenticatorTest (in coilmq.tests.test_auth)	synchronized() (in coilmq.util.concurrency)

T

tearDown() (in BaseFunctionalTestCase)	test_dequeue_order() (in CommonQueueTestsMixin)	test_send_err() (in QueueManagerTest)
tearDown() (in BaseFunctionalTestCase)	test_dequeue_order() (in CommonQueueTestsMixin)	test_send_receipt() (in BasicTest)
tearDown() (in DbmQueueTest)	test_dequeue_order() (in SAQueueTest)	test_send_receipt() (in BasicTest)
tearDown() (in SAQueueTest)	test_dequeue_specific() (in CommonQueueTestsMixin)	test_send_reliableFirst() (in QueueManagerTest)
tearDown() (in SimpleAuthenticatorTest)	test_dequeue_specific() (in CommonQueueTestsMixin)	test_send_reliableFirst() (in QueueManagerTest)
tearDown() (in EngineTest)	test_disconnect() (in BasicTest)	test_send_utf8() (in BasicTest)
test_abort() (in EngineTest)	test_disconnect() (in BasicTest)	test_send_utf8() (in BasicTest)
test_abort_invalid() (in EngineTest)	test_disconnect_pending_frames() (in QueueManagerTest)	test_subscribe() (in BasicTest)
test_ack_basic() (in QueueManagerTest)	test_disconnect_pending_frames() (in QueueManagerTest)	test_subscribe() (in BasicTest)
test_ack_basic() (in QueueManagerTest)	test_engine (in coilmq.tests)	test_subscribe() (in QueueManagerTest)
test_ack_transaction() (in QueueManagerTest)	test_enqueue() (in CommonQueueTestsMixin)	test_subscribe() (in QueueManagerTest)
test_ack_transaction() (in QueueManagerTest)	test_enqueue() (in CommonQueueTestsMixin)	test_subscribe() (in TopicManagerTest)
test_auth (in coilmq.tests)	test_favorReliable() (in QueueDeliverySchedulerTest)	test_subscribe_ack() (in EngineTest)
test_basic (in coilmq.tests.functional)	test_from_configfile() (in SimpleAuthenticatorTest)	test_subscribe_noack() (in EngineTest)
test_basic_sa (in coilmq.tests.functional)	test_from_configfile_fp() (in SimpleAuthenticatorTest)	test_sync_checkpoint_ops() (in DbmQueueTest)
test_begin() (in EngineTest)	test_from_configfile_fp_invalid() (in SimpleAuthenticatorTest)	test_sync_checkpoint_timeout() (in DbmQueueTest)
test_commit() (in EngineTest)	test_from_configfile_invalid() (in SimpleAuthenticatorTest)	test_sync_close() (in DbmQueueTest)
test_commit_invalid() (in EngineTest)	test_memory (in coilmq.tests.store)	test_sync_loss() (in DbmQueueTest)
test_connect() (in BasicTest)	test_queue (in coilmq.tests)	test_topic (in coilmq.tests)
test_connect() (in BasicTest)	test_queue_dbm (in coilmq.tests)	test_unsubscribe() (in EngineTest)
test_connect_auth() (in BasicTest)	test_queue_sa (in coilmq.tests)	test_unsubscribe() (in QueueManagerTest)
test_connect_auth() (in BasicTest)	test_receipt() (in EngineTest)	test_unsubscribe() (in QueueManagerTest)
test_connect_auth() (in EngineTest)	test_sa (in coilmq.tests.store)	test_unsubscribe() (in TopicManagerTest)
test_connect_no_auth() (in EngineTest)	test_scheduler (in coilmq.tests)	tests (in coilmq)
test_constructor() (in SimpleAuthenticatorTest)	test_send() (in EngineTest)	TestStompClient (in coilmq.tests.functional)
test_dbm (in coilmq.tests.store)	test_send_backlog_err_reliable() (in QueueManagerTest)	TestStompServer (in coilmq.tests.functional)
test_dequeue() (in CommonQueueTestsMixin)	test_send_backlog_err_reliable() (in QueueManagerTest)	ThreadedStompServer (in coilmq.server.socketserver)
test_dequeue() (in CommonQueueTestsMixin)	test_send_backlog_err_unreliable() (in QueueManagerTest)	topic (in coilmq)
test_dequeue_empty() (in CommonQueueTestsMixin)	test_send_backlog_err_unreliable() (in QueueManagerTest)	TopicManager (in coilmq.topic)
test_dequeue_empty() (in CommonQueueTestsMixin)	test_send_binary() (in BasicTest)	TopicManagerTest (in coilmq.tests.test_topic)
test_dequeue_identity() (in DbmQueueTest)	test_send_binary() (in BasicTest)	TopicStore (in coilmq.store)
test_dequeue_identity() (in MemoryQueueTest)	test_send_err() (in QueueManagerTest)

U

unbind() (in StompEngine)	unsubscribe() (in MockQueueManager)	util (in coilmq)
unsubscribe() (in StompEngine)	unsubscribe() (in MockTopicManager)
unsubscribe() (in QueueManager)	unsubscribe() (in TopicManager)

V

VALID_COMMANDS (in coilmq.engine)

_

__init__() (in SimpleAuthenticator)	__init__() (in MemoryQueue)	__len__() (in QueueFrameIterator)
__init__() (in StompEngine)	__init__() (in TestStompClient)	__metaclass__ (in Authenticator)
__init__() (in QueueManager)	__init__() (in TestStompServer)	__metaclass__ (in SubscriberPriorityScheduler)
__init__() (in StompServer)	__init__() (in MockConnection)	__metaclass__ (in StompConnection)
__init__() (in QueueFrameIterator)	__init__() (in MockQueueManager)	__metaclass__ (in QueueStore)
__init__() (in QueueStore)	__init__() (in MockTopicManager)	__nonzero__() (in QueueFrameIterator)
__init__() (in QueueStore)	__init__() (in TopicManager)
__init__() (in DbmQueue)	__iter__() (in QueueFrameIterator)