Method List
-
#add_handler SuperPoller::Router
-
#any? SuperPoller::StarlingQueue
-
buffer_size SuperPoller::BufferedHandler
-
#call SuperPoller::Handler
-
#call SuperPoller::AggregatingErrorLogger
-
#call SuperPoller::Stats
-
#call SuperPoller::ErrorReporter
-
#call SuperPoller::Router
-
#call SuperPoller::BufferedHandler
-
#can_handle? SuperPoller::Handler
-
#coerce SuperPoller::StarlingQueue
-
#destroy_the_memo SuperPoller::QueueIterator
-
#each SuperPoller::QueueIterator
-
#empty? SuperPoller::StarlingQueue
-
#ensure_worker_is_running SuperPoller::Stats
-
#fetch SuperPoller::StarlingQueue
-
#fix_encoding SuperPoller::StarlingQueue
-
#flush SuperPoller::StarlingQueue
-
#handle_batch SuperPoller::BufferedHandler
-
#handler SuperPoller::Handler::TestCase
-
handles SuperPoller::Handler
-
#initialize SuperPoller::ErrorReporter
-
#initialize SuperPoller::QueueIterator
-
#initialize SuperPoller::RetryWrapper
-
#initialize SuperPoller::StarlingQueue
-
#initialize SuperPoller::Router
-
#initialize SuperPoller::Poller
-
#initialize SuperPoller::Stats
-
#initialize SuperPoller::AggregatingErrorLogger
-
#initialize SuperPoller::BufferedHandler
-
#length SuperPoller::StarlingQueue
-
max_buffer_size SuperPoller::BufferedHandler
-
message_names SuperPoller::Handler
-
parse SuperPoller::QueueUrl
-
#poll SuperPoller::Poller
-
#pop SuperPoller::StarlingQueue
-
#push SuperPoller::StarlingQueue
-
should_handle SuperPoller::Handler::TestCase
-
#start! SuperPoller::Poller
-
#start! SuperPoller::NoneBlockingPoller
-
#to_queue SuperPoller::QueueUrl