소스 검색

Merge pull request #1831 from eyvoro/patch-1

Fixed basic.publish command in celery amqp program
Ask Solem Hoel 11 년 전
부모
커밋
59e44ae630
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      celery/bin/amqp.py

+ 1 - 1
celery/bin/amqp.py

@@ -175,7 +175,7 @@ class AMQShell(cmd.Cmd):
         'basic.get': Spec(('queue', str),
                           ('no_ack', bool, 'off'),
                           returns=dump_message),
-        'basic.publish': Spec(('msg', Message),
+        'basic.publish': Spec(('msg', str),
                               ('exchange', str),
                               ('routing_key', str),
                               ('mandatory', bool, 'no'),