gmr on master
Fix the link and alpha order of… (compare)
gmr on master
Fix the version number (compare)
gmr on 0.10.0b1
Fix the version number (compare)
gmr on 0.10.0b1
gmr on 0.10.0b1
gmr on master
Change the version scheme (compare)
gmr on 0.10.dev0
gmr on 0.9.dev0
gmr on 0.9.0
gmr on v0.9a
gmr on v0.9.1a
gmr on v0.9.2a
gmr on v0.9.3
gmr on v0.9.4
gmr on v0.9.5
gmr on 0.9.5
gmr on 0.9.4
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
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?
add_callback_threadsafe
method on the BlockingConnection
class. I am trying to publish a message to a random exchange. Previously I used only basic_publish
and 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:add_callback_threadsafe
actually not work for single thread scenarios (and may this be the cause)?