<html><head><style type='text/css'>p { margin: 0; }</style></head><body><div style='font-family: Times New Roman; font-size: 12pt; color: #000000'><P>Hi Sergey,</P>
<P>I'm not the most experienced about the pika, but I would recommend using normal Exception handling around the connection and queue setup, and also around your processing code, so that it doesn't interfere with the normal running of the processing. If you record the exception messages somewhere, you will be able to get more information about the failure.</P>
<P> </P>
<P>Your exact needs may differ, but our java tutorial at <A href="https://github.com/rabbitmq/rabbitmq-tutorials/blob/master/java/RPCServer.java">https://github.com/rabbitmq/rabbitmq-tutorials/blob/master/java/RPCServer.java</A> has some Exception context (the "try" blocks) which may be helpful. Unfortunately, we don't have such an example for the pika.</P>
<P> </P>
<P>I hope to add some guidance on exceptions to our documentation at some point soon.</P>
<P>Ann</P>
<P>
<HR id=zwchr>
</P>
<DIV style="FONT-STYLE: normal; FONT-FAMILY: Helvetica,Arial,sans-serif; COLOR: #000; FONT-SIZE: 12pt; FONT-WEIGHT: normal; TEXT-DECORATION: none"><B>From: </B>"Sergey Almazov" <sergey.almazoff@gmail.com><BR><B>To: </B>rabbitmq-discuss@lists.rabbitmq.com<BR><B>Sent: </B>Wednesday, 7 September, 2011 6:39:59 AM<BR><B>Subject: </B>[rabbitmq-discuss] pika error - need a help<BR><BR><SPAN style="BACKGROUND-COLOR: rgb(255,255,255); FONT-FAMILY: arial, sans-serif; FONT-SIZE: 13px" class=Apple-style-span>
<DIV>#!/usr/bin/env python</DIV>
<DIV>import pika</DIV>
<DIV>import sys</DIV>
<DIV>import psutil</DIV>
<DIV>import json</DIV>
<DIV>import time</DIV>
<DIV><BR></DIV>
<DIV>serverName = "salmazov"</DIV>
<DIV>connection = pika.AsyncoreConnection(pika.ConnectionParameters(host='192.168.0.25'))</DIV>
<DIV>channel = connection.channel()</DIV>
<DIV><BR></DIV>
<DIV>channel.exchange_declare(exchange='cmd', type='topic')</DIV>
<DIV><BR></DIV>
<DIV>cmd_data_queue = channel.queue_declare(exclusive=True).queue</DIV>
<DIV><BR></DIV>
<DIV>channel.queue_bind(exchange='cmd', queue=cmd_data_queue, routing_key='cmd.*')</DIV>
<DIV><BR></DIV>
<DIV>def callback(ch, method, properties, body):</DIV>
<DIV> print " [x] %r:%r" % (method.routing_key, body,)</DIV>
<DIV> procCmd = decodeddict["ProcCmd"]</DIV>
<DIV> proc = psutil.Popen(procCmd)</DIV>
<DIV> </DIV>
<DIV>channel.basic_consume(callback, queue=cmd_data_queue, no_ack=True)</DIV>
<DIV>pika.asyncore_loop()</DIV>
<DIV>--------------------------------------------</DIV>
<DIV><BR></DIV>
<DIV>When I start this code -> have an error: <B>error: uncaptured python exception, closing channel <pika.asyncore_adapter.RabbitDispatcher connected at 0x12ad6c0></B></DIV>
<DIV><B><BR></B></DIV>
<DIV>I need to run processes that arrived via RmQ</DIV></SPAN><BR>_______________________________________________<BR>rabbitmq-discuss mailing list<BR>rabbitmq-discuss@lists.rabbitmq.com<BR>https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<BR></DIV><BR></div></body></html>