Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Update the readme to reflect the renamed modules and classes

  • Loading branch information...
commit c584cc7d998249c38c0fa4e7443d89afb9a3feca 1 parent 47abd31
Gavin M. Roy authored
Showing with 4 additions and 5 deletions.
  1. +3 −4 README.md
  2. +1 −1  rejected/mcp.py
View
7 README.md
@@ -11,9 +11,9 @@ data from the consumer processes and report on it.
Example Processor
-----------------
- from rejected import processor
+ from rejected import consumer
- class Test(processor.Processor):
+ class Test(consumer.COnsumer):
def process(self, message):
self._logger.debug('In Test.process: %s' % message.body)
@@ -35,8 +35,7 @@ Example Configuration
vhost: /
Consumers:
test_processor:
- import: test_processor
- processor: Test
+ consumer: test_processor.Test
connections: [rabbitmq]
queue: test_queue
min: 2
View
2  rejected/mcp.py
@@ -336,7 +336,7 @@ def _poll_duration_exceeded(self):
"""
return (time.time() -
self._poll_data['timestamp']) >= self._poll_interval
-
+
def _poll_results_check(self):
"""Check the polling results by checking to see if the stats queue is
empty. If it is not, try and collect stats. If it is set a timer to
Please sign in to comment.
Something went wrong with that request. Please try again.