Re: [Txamqp-user] Sending from a for loop

Hi On Tue, Aug 11, 2009 at 6:22 PM, Dan Reverri wrote: > It sends 5 messages without callInThread, than 5 messages with callInThread: >    send_msgs_from_for_loop(channel) >    reactor.callInThread(send_msgs_from_for_loop, channel, True) Could you test this script? http://pastie.org/580287 it's

Re: [Txamqp-user] Sending from a for loop

Hey Esteve, I do not think you can just use callFromThread alone, I believe you have to use callInThread first to push the context to another thread and than use callFromThread to access transport.write() from the thread. It seems the patch works only if I push my send loop to another thread: rea

Re: [Txamqp-user] Sending from a for loop

Hi On Tue, Aug 11, 2009 at 10:12 AM, Esteve Fernandez wrote: > I thought that using callFromThread(self.transport.write, data) would > solve that problem, but I'm afraid it didn't. That's weird, I just tried callFromThread again, and everything worked fine. I think I was using Twisted 2.5.0 when

Re: [Txamqp-user] Sending from a for loop

Hi On Mon, Aug 10, 2009 at 7:11 AM, Dan Reverri wrote: > Can anyone suggest a method of sending messages generated from a list > of values in a such way that the send function is processed > immediately? > > The send() function does not block and if called from within a for > loop, it will not be