Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Jul 11 2015 00:15
    vitaly-krugl commented #623
  • Jul 11 2015 00:09
    gmr commented #623
  • Jul 10 2015 23:57

    gmr on master

    Fix the link and alpha order of… (compare)

  • Jul 10 2015 23:52

    gmr on master

    Fix the version number (compare)

  • Jul 10 2015 23:51

    gmr on 0.10.0b1

    Fix the version number (compare)

  • Jul 10 2015 23:49
    vitaly-krugl commented #623
  • Jul 10 2015 23:49

    gmr on 0.10.0b1

    (compare)

  • Jul 10 2015 23:49

    gmr on 0.10.0b1

    (compare)

  • Jul 10 2015 23:49

    gmr on master

    Change the version scheme (compare)

  • Jul 10 2015 23:48

    gmr on 0.10.dev0

    (compare)

  • Jul 10 2015 23:47

    gmr on 0.9.dev0

    (compare)

  • Jul 10 2015 23:46

    gmr on 0.9.0

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9a

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9.1a

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9.2a

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9.3

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9.4

    (compare)

  • Jul 10 2015 23:44

    gmr on v0.9.5

    (compare)

  • Jul 10 2015 23:43

    gmr on 0.9.5

    (compare)

  • Jul 10 2015 23:43

    gmr on 0.9.4

    (compare)

Red-Lv
@Red-Lv
HI， I am using pika in production enviroment.
But I came across the exception. 
424 ERROR: 11-15 01:44:12: mg * [logid: 26022] [base_connection.py: 299] Socket Error on fd 7: 104
425 WARNING: 11-15 01:44:12: mg * [logid: 26022] [base_connection.py: 160] Socket closed when connection was open
426 Exception in thread Thread-4:
427 Traceback (most recent call last):
428   File "/home/work/local/python-2.7.3/lib/python2.7/threading.py", line 551, in __bootstrap_inner
429     self.run()
430   File "/home/work/local/python-2.7.3/lib/python2.7/threading.py", line 504, in run
431     self.__target(*self.__args, **self.__kwargs)
432   File "entity_aggregation.py", line 71, in publish
433     RabbitMQClient.publish(self, routing_key=routing_key, body=msg)
434   File "/home/work/Online_Env/entity_aggregation/packages/abstract/rabbitmq_client.py", line 143, in publish
435     self.producer_channel.basic_publish(exchange=exchange, routing_key=routing_key, body=body)
436   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 572, in basic_publish
437     (properties, body), False)
438   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 1159, in _send_method
439     self.connection.send_method(self.channel_number, method_frame, content)
440   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 274, in send_method
441     self._send_method(channel_number, method_frame, content)
442   File "build/bdist.linux-x86_64/egg/pika/connection.py", line 1503, in _send_method
443     self._send_frame(frame.Method(channel_number, method_frame))
444   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 417, in _send_frame
445     super(BlockingConnection, self)._send_frame(frame_value)
446   File "build/bdist.linux-x86_64/egg/pika/connection.py", line 1490, in _send_frame
447     self._flush_outbound()
448   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 377, in _flush_outbound
449     if self._handle_write():
450   File "build/bdist.linux-x86_64/egg/pika/adapters/base_connection.py", line 365, in _handle_write
451     return self._handle_error(error)
452   File "build/bdist.linux-x86_64/egg/pika/adapters/base_connection.py", line 302, in _handle_error
453     self._handle_disconnect()
454   File "build/bdist.linux-x86_64/egg/pika/adapters/base_connection.py", line 248, in _handle_disconnect
455     self._adapter_disconnect()
456   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 318, in _adapter_disconnect
457     self._check_state_on_disconnect()
458   File "build/bdist.linux-x86_64/egg/pika/adapters/blocking_connection.py", line 371, in _check_state_on_disconnect
459     raise exceptions.ConnectionClosed()
460 ConnectionClosed
which appears when publishing messages after a long idle period.
Is there some solutions?
Gavin M. Roy
@gmr
It looks like you’re disconnected from RabbitMQ — any other context other than “long idle period?” are you disabling heartbeats or using time.sleep(), or any other type of activity that would cause RabbitMQ to close the socket?
Rahul Maheshwari
@rmaheshwari

@rmaheshwari

Hi all .. Is there a way we can broadcast the message from rabbit mq to the consumers without using fanout , topics
we have an existing application which demands to send same message to all consumer

chaitu2289
@chaitu2289
can anyone help me on this error. I have implemented RPC where server reads messages from client and after processing finished, server writes to client queue. But I am getting following error. Cant able to figure out
Traceback (most recent call last):
File "server.py", line 6, in <module>
r.listen()
File "caffe/home/receiver.py", line 36, in listen
channel.start_consuming()
File "anaconda/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 917, in start_consuming
self.connection.process_data_events()
File "anaconda/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 218, in process_data_events
raise exceptions.ConnectionClosed()
pika.exceptions.ConnectionClosed
chaitu2289
@chaitu2289
For further information, I am transferring images, and I have changed the heartbeat configuration in the server according to that. Does the connection closed issue because of large data transfer. Please help me in resolving this issue
Jon Major
@jonmajorc
Hey, anyone here?
DIfyzz
@ifiokidiang_twitter
Hi guys
On consuming from RabbitMQ
I am getting this error: 
Error consuming from queue Probably rabbit MQ connection'NoneType' object has no attribute 'sendall'

Expecting property name: line 1 column 2 (char 1)
Anyone experienced this or know what the cause is?
PeterPan4d
@PeterPan4d
Hi! Can anyone help me? I did setup a hello world example with RabbitMQ but starting my consumer triggers to messages although the original producer isn't even running anymore
So when I restart my consumer, again, I get two incoming messages
Any idea which could have caused this?
My management view says there are two unack messages in the queue, but why?
Michael Recachinas
@mrecachinas
Are there any plans to support clustered-connections within pika? I'm specifically looking for the ability to fall-back from one connection to another IP in the cluster (without an external proxy -- e.g., NGINX, HAPROXY, etc.).
Michael Recachinas
@mrecachinas
Nevermind, it’s on pika’s readme. That’s my bad.
João Dias Conde Azevedo
@joao-conde
Hello channel! I am having some strange behavior with the infamous add_callback_threadsafe method on the BlockingConnectionclass. I am trying to publish a message to a random exchange. Previously I used only basic_publishand it worked. However, I was concerned with the multi-thread safety of the code so I am trying the aforementioned threadsafe method. Now, no message is published. So I really have two questions:
1 - Does add_callback_threadsafe actually not work for single thread scenarios (and may this be the cause)?
2- If not, does anyone have any idea?
Furthermore, I'm happy to provide more details if need be, I'm keeping it short because it is a chat but if you need more details ask me anything.