Index

A

add_duration() (rejected.data.Measurement method) app_id (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

AsyncTestCase (class in rejected.testing)

B

body (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

C

Consumer (class in rejected.consumer) ConsumerException (class in rejected.consumer) content_encoding (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) content_type (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

correlation_id (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) create_message() (rejected.testing.AsyncTestCase method)

D

decr() (rejected.data.Measurement method)

E

exchange (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

expiration (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

F

finish() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

G

gen_test() (in module rejected.testing)

get_consumer() (rejected.testing.AsyncTestCase method) get_settings() (rejected.testing.AsyncTestCase method)

H

headers (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

I

incr() (rejected.data.Measurement method) initialize() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

io_loop (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

M

Measurement (class in rejected.data) measurement (rejected.testing.AsyncTestCase attribute) Message (class in rejected.data) message_age_key() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) message_id (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

message_type (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) MessageException (class in rejected.consumer)

N

name (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

O

on_blocked() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) on_finish() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

on_unblocked() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

P

prepare() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) priority (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) process() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) process_message() (rejected.testing.AsyncTestCase method)

ProcessingException (class in rejected.consumer) Properties (class in rejected.data) properties (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) publish_message() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) published_messages (rejected.testing.AsyncTestCase attribute) PublishedMessage (class in rejected.testing) PublishingConsumer (class in rejected.consumer)

R

redelivered (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) rejected.data (module) rejected.testing (module) RejectedException (class in rejected.consumer) reply() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

reply_to (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) returned (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) routing_key (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

S

send_exception_to_sentry() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) sentry_client (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) set_sentry_context() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) set_tag() (rejected.data.Measurement method) set_value() (rejected.data.Measurement method) settings (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute) setUp() (rejected.testing.AsyncTestCase method) shutdown() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) SmartConsumer (class in rejected.consumer) SmartPublishingConsumer (class in rejected.consumer) stats_add_duration() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) stats_add_timing() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

stats_incr() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) stats_set_tag() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) stats_set_value() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) stats_track_duration() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) statsd_add_timing() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) statsd_incr() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method) statsd_track_duration() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

T

tearDown() (rejected.testing.AsyncTestCase method) timestamp (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

track_duration() (rejected.data.Measurement method)

U

unset_sentry_context() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)

user_id (rejected.consumer.Consumer attribute) (rejected.consumer.PublishingConsumer attribute) (rejected.consumer.SmartConsumer attribute) (rejected.consumer.SmartPublishingConsumer attribute)

Y

yield_to_ioloop() (rejected.consumer.Consumer method) (rejected.consumer.PublishingConsumer method) (rejected.consumer.SmartConsumer method) (rejected.consumer.SmartPublishingConsumer method)