Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
  • 7 commits
  • 1 file changed
  • 0 commit comments
  • 1 contributor
Showing with 4 additions and 2 deletions.
  1. +4 −2 scripts/stress_test
View
6 scripts/stress_test
@@ -78,7 +78,8 @@ class ChannelTest:
self._ch.queue.bind( self._queue, self._exchange, self._queue )
self._ch.basic.consume( self._queue, self._consume )
- self._publish()
+ #self._publish()
+ event.timeout( 1, self._publish )
@property
def _transactions(self):
@@ -95,7 +96,8 @@ class ChannelTest:
# 2.4.0 can handle the handshake of channel close before we handshake the
# connection close. Otherwise, it gets both close requests in rapid
# succession and doesn't ack either of them, resulting in a force quit
- event.timeout( 0.3, channel_closed, self )
+ #event.timeout( 0.3, channel_closed, self )
+ channel_closed(self)
def _publish(self):
self._count += 1

No commit comments for this range

Something went wrong with that request. Please try again.