[rabbitmq-discuss] Pika AttributeError: Channel instance has no attribute 'start_consuming'

[KooT]

python worker.py
[*] Waiting for messages. To exit press CTRL+C
Traceback (most recent call last):
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'


I got pika 0.9.5

[Gavin M. Roy]

Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com (mailto:rabbitmq-discuss at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110531/f40f5596/attachment.htm>

[KooT]

Yes, its worker.py from http://www.rabbitmq.com/tutorials/tutorial-two-python.html

#!/usr/bin/env python
import pika
import time

connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'

def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')

channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
?[*] Waiting for messages. To exit press CTRL+C
?File "worker.py", line 22, in ?
?channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[Gavin M. Roy]

Sounds like it may not be Pika 0.9.5, how did you install?

What output do you get if you do:

python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com)

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110531/6c907fa6/attachment-0001.htm>

[KooT]

Downloaded source pika-0.9.5.tar.gz and then utar pika dir to the same
dir where is worker.py


rkot at a0:~$ ls -lah pika
total 412K
drwxr-xr-x 2 rkot 1000 4.0K 2011-05-31 20:16 .
drwxr-xr-x 22 rkot 1000 8.0K 2011-05-31 20:17 ..
-rw-r--r-- 1 rkot 1000 5.1K 2011-05-31 13:31 asyncore_adapter.py
-rw-r--r-- 1 rkot 1000 4.7K 2011-05-31 20:16 asyncore_adapter.pyc
-rw-r--r-- 1 rkot 1000 3.2K 2011-05-31 13:31 blocking_adapter.py
-rw-r--r-- 1 rkot 1000 1.5K 2011-05-31 20:16 blocking_adapter.pyc
-rw-r--r-- 1 rkot 1000 12K 2011-05-31 13:31 channel.py
-rw-r--r-- 1 rkot 1000 8.8K 2011-05-31 20:16 channel.pyc
-rw-r--r-- 1 rkot 1000 7.9K 2011-05-31 13:31 codec.py
-rw-r--r-- 1 rkot 1000 6.7K 2011-05-31 20:16 codec.pyc
-rw-r--r-- 1 rkot 1000 18K 2011-05-31 13:31 connection.py
-rw-r--r-- 1 rkot 1000 17K 2011-05-31 20:16 connection.pyc
-rw-r--r-- 1 rkot 1000 3.0K 2011-05-31 13:31 event.py
-rw-r--r-- 1 rkot 1000 1.4K 2011-05-31 20:16 event.pyc
-rw-r--r-- 1 rkot 1000 2.8K 2011-05-31 13:31 exceptions.py
-rw-r--r-- 1 rkot 1000 2.5K 2011-05-31 20:16 exceptions.pyc
-rw-r--r-- 1 rkot 1000 2.9K 2011-05-31 13:31 __init__.py
-rw-r--r-- 1 rkot 1000 1.1K 2011-05-31 20:16 __init__.pyc
-rw-r--r-- 1 rkot 1000 5.3K 2011-05-31 13:31 simplebuffer.py
-rw-r--r-- 1 rkot 1000 4.1K 2011-05-31 20:16 simplebuffer.pyc
-rw-r--r-- 1 rkot 1000 3.1K 2011-05-31 13:31 specbase.py
-rw-r--r-- 1 rkot 1000 2.0K 2011-05-31 20:16 specbase.pyc
-rw-r--r-- 1 rkot 1000 118K 2011-05-31 13:31 spec.py
-rw-r--r-- 1 rkot 1000 106K 2011-05-31 20:16 spec.pyc
-rw-r--r-- 1 rkot 1000 5.2K 2011-05-31 13:31 table.py
-rw-r--r-- 1 rkot 1000 2.5K 2011-05-31 20:16 table.pyc

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
? ? ? ?host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
? ?print " [x] Received %r" % (body,)
? ?time.sleep( body.count('.') )
? ?print " [x] Done"
? ?ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
? ? ? ? ? ? ? ? ? ? ?queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
?[*] Waiting for messages. To exit press CTRL+C
?File "worker.py", line 22, in ?
?channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com)

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[KooT]

rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
Traceback (most recent call last):
File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
? ? ? ?host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
? ?print " [x] Received %r" % (body,)
? ?time.sleep( body.count('.') )
? ?print " [x] Done"
? ?ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
? ? ? ? ? ? ? ? ? ? ?queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
?[*] Waiting for messages. To exit press CTRL+C
?File "worker.py", line 22, in ?
?channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com)

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[Gavin M. Roy]

That doesn't look like a 0.9.5 install.

Have you tried pip or easy_install?

gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com (mailto:rabbitmq-discuss at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110531/9decbb1c/attachment.htm>

[KooT]

I don't have root access there, i want pika as local lib :|

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
?File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[Gavin M. Roy]

Is it possible that an older version of pika is also installed in the global scope?

You could install in virtualenv to keep it local:

gmr at binti ~ $ virtualenv --no-site-packages test
New python executable in test/bin/python2.6
Also creating executable in test/bin/python
Installing setuptools............done.
Installing pip...............done.
gmr at binti ~ $ cd test/
gmr at binti ~/test $ ls
bin include lib lib64
gmr at binti ~/test $ source bin/activate
(test)gmr at binti ~/test $ pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
(test)gmr at binti ~/test $ python -c "import pika;print pika.__version__"
0.9.5
(test)gmr at binti ~/test $

Post by KooT
I don't have root access there, i want pika as local lib :|

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com (mailto:rabbitmq-discuss at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110531/d4d88a85/attachment-0001.htm>

[KooT]

I had open 'mc', and on right panel there wasn't my home dir :)
Will try virtualenv. Again, thank You for Your time! very much
appreciate it!

Post by Gavin M. Roy
Is it possible that an older version of pika is also installed in the global scope?
gmr at binti ~ $ virtualenv --no-site-packages test
New python executable in test/bin/python2.6
Also creating executable in test/bin/python
Installing setuptools............done.
Installing pip...............done.
gmr at binti ~ $ cd test/
gmr at binti ~/test $ ls
bin include lib lib64
gmr at binti ~/test $ source bin/activate
(test)gmr at binti ~/test $ pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
(test)gmr at binti ~/test $ python -c "import pika;print pika.__version__"
0.9.5
(test)gmr at binti ~/test $

Post by KooT
I don't have root access there, i want pika as local lib :|

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(...)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[KooT]

You are right.

rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
0.9.5

It was old pika dir... i dont know how... b

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
?File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[KooT]

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
?File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

[KooT]

Thank You very much for Your time and help!

Post by Gavin M. Roy
That doesn't look like a 0.9.5 install.
Have you tried pip or easy_install?
gmr at binti ~ $ sudo pip install pika
Downloading/unpacking pika
Downloading pika-0.9.5.tar.gz
Running setup.py egg_info for package pika
Installing collected packages: pika
Running setup.py install for pika
Successfully installed pika
Cleaning up...
gmr at binti ~ $ python -c "import pika;print pika.__version__"
0.9.5

Post by KooT
rkot at a0:~$ python2.7 -c "import pika;print pika.__version__"
?File "<string>", line 1, in <module>
AttributeError: 'module' object has no attribute '__version__'

Post by Gavin M. Roy
Sounds like it may not be Pika 0.9.5, how did you install?
python -c "import pika;print pika.__version__"

Post by KooT
Yes, its worker.py from
http://www.rabbitmq.com/tutorials/tutorial-two-python.html
#!/usr/bin/env python
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
print " [x] Received %r" % (body,)
time.sleep( body.count('.') )
print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback,
queue='task_queue')
channel.start_consuming()

Post by Gavin M. Roy
Are you using the BlockingConnection adapter?

Post by KooT
python worker.py
[*] Waiting for messages. To exit press CTRL+C
File "worker.py", line 22, in ?
channel.start_consuming()
AttributeError: Channel instance has no attribute 'start_consuming'
I got pika 0.9.5
_______________________________________________
rabbitmq-discuss mailing list

rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com))

Post by Gavin M. Roy

Post by KooT
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://

lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss (http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (http://lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss(http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss)

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.com (mailto:rabbitmq-disc... at lists.rabbitmq.com)
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss