summaryrefslogtreecommitdiff
path: root/scripts/queue_mover.py
diff options
context:
space:
mode:
authorTarvi Pillessaar2012-09-12 12:38:52 +0000
committerTarvi Pillessaar2012-09-12 12:38:52 +0000
commit25972620343f4acd48a4e4c82d1e5d7e94aff15d (patch)
tree3a816df4cebf44db7917e05d5d3de9e95198fcd3 /scripts/queue_mover.py
parente1c22bd6d598dcf86a2a930bd19904e330b085b6 (diff)
scripts: changed queue_mover and queue_splitter service_name
Diffstat (limited to 'scripts/queue_mover.py')
-rwxr-xr-xscripts/queue_mover.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/scripts/queue_mover.py b/scripts/queue_mover.py
index 0631bfcf..24af739f 100755
--- a/scripts/queue_mover.py
+++ b/scripts/queue_mover.py
@@ -23,7 +23,7 @@ class QueueMover(pgq.SerialConsumer):
__doc__ = __doc__
def __init__(self, args):
- pgq.SerialConsumer.__init__(self, "queue_mover", "src_db", "dst_db", args)
+ pgq.SerialConsumer.__init__(self, "queue_mover3", "src_db", "dst_db", args)
self.dst_queue_name = self.cf.get("dst_queue_name")
def process_remote_batch(self, db, batch_id, ev_list, dst_db):