diff options
| author | Stanislav Kudriashev <skudriashev@griddynamics.com> | 2014-03-19 14:49:13 +0200 |
|---|---|---|
| committer | Stanislav Kudriashev <skudriashev@griddynamics.com> | 2014-03-20 11:43:55 +0200 |
| commit | 4252eb02779a8399740fd04a37ec67ebd274d866 (patch) | |
| tree | 09da144d95a7fe6bc508a93badf998babd8dd724 /taskflow/engines/worker_based/proxy.py | |
| parent | bb6cf4cd2c098c75975a60a35b62dd71dcb3e119 (diff) | |
| download | taskflow-4252eb02779a8399740fd04a37ec67ebd274d866.tar.gz | |
Improve logging for proxy publish
Added message type logging during proxy publishing.
Change-Id: Iddbfab0e4dd6e9f5b6d1c3ea5c86029700a2d66d
Diffstat (limited to 'taskflow/engines/worker_based/proxy.py')
| -rw-r--r-- | taskflow/engines/worker_based/proxy.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/taskflow/engines/worker_based/proxy.py b/taskflow/engines/worker_based/proxy.py index 7fc3fb7..1265f9e 100644 --- a/taskflow/engines/worker_based/proxy.py +++ b/taskflow/engines/worker_based/proxy.py @@ -69,6 +69,7 @@ class Proxy(object): def publish(self, msg, routing_key, **kwargs): """Publish message to the named exchange with routing key.""" + LOG.debug("Sending %s", msg) if isinstance(routing_key, six.string_types): routing_keys = [routing_key] else: |