This new script works; I assumed you wanted me to test without the
previous patch. Messages are sent without waiting for the for loop to
complete.
___
Mailing list: https://launchpad.net/~txamqp-user
Post to : txamqp-user@lists.launchpad.net
Unsubscr
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
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
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
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
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 processed until after the for loop has completed.
Here is an examp
6 matches
Mail list logo