Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Fixed order of consumer names in pubsub script

  • Loading branch information...
commit dcae3c77269384ded2e5598c942bb4965e3a9969 1 parent 175a256
David Stuebe authored
Showing with 10 additions and 4 deletions.
  1. +2 −0  README.txt
  2. +8 −4 res/scripts/pubsub.py
2  README.txt
View
@@ -45,6 +45,8 @@ Alternatively (better) from UNIX shell executing a script:
::
twistd -n magnet -h amoeba.ucsd.edu res/scripts/bootstrap.py
twistd -n magnet -h amoeba.ucsd.edu res/scripts/newcc.py
+ twistd -n magnet -h amoeba.ucsd.edu -a nproducers=25 res/scripts/pubsub.py
+
Run trial test cases (recursively)
::
12 res/scripts/pubsub.py
View
@@ -3,7 +3,11 @@
"""
@file res/scripts/pubsub.py
@author David Stuebe
-@brief main module for bootstrapping dm pubsub services
+@brief main module for bootstrapping dm pubsub services test
+This test creates a configurable number of publisher processes using the
+nproducers argument from the command line. The default configuration of the
+script creates a subscription workflow which process the results and creates
+an aggregate statement in the log about the number of data events.
"""
import random
@@ -117,15 +121,15 @@ def start():
{'module':'ion.services.dm.distribution.consumers.example_consumer',
'consumerclass':'ExampleConsumer',\
'attach':'topic1'},
- 'consumer3':
+ 'consumer2':
{'module':'ion.services.dm.distribution.consumers.message_count_consumer',
'consumerclass':'MessageCountConsumer',\
'attach':[['consumer1','event_queue']],\
'delivery interval':10},
- 'consumer2':
+ 'consumer3':
{'module':'ion.services.dm.distribution.consumers.logging_consumer',
'consumerclass':'LoggingConsumer',\
- 'attach':[['consumer3','queue']]}
+ 'attach':[['consumer2','queue']]}
}
Please sign in to comment.
Something went wrong with that request. Please try again.