@@ -161,7 +161,7 @@ class WaitableListener(object):
161
161
def __init__ (self ):
162
162
self .debug = False
163
163
if self .debug :
164
- print '(listener) init'
164
+ print ( '(listener) init' )
165
165
self .messages = []
166
166
self .errors = []
167
167
self .receipts = []
@@ -179,17 +179,17 @@ def _append(self, array, msg, hdrs):
179
179
180
180
def on_receipt (self , headers , message ):
181
181
if self .debug :
182
- print '(on_receipt) message:' , message , ' headers:' , headers
182
+ print ( '(on_receipt) message: {}, headers: {}' . format ( message , headers ))
183
183
self ._append (self .receipts , message , headers )
184
184
185
185
def on_error (self , headers , message ):
186
186
if self .debug :
187
- print '(on_error) message:' , message , ' headers:' , headers
187
+ print ( '(on_error) message: {}, headers: {}' . format ( message , headers ))
188
188
self ._append (self .errors , message , headers )
189
189
190
190
def on_message (self , headers , message ):
191
191
if self .debug :
192
- print '(on_message) message:' , message , ' headers:' , headers
192
+ print ( '(on_message) message: {}, headers: {}' . format ( message , headers ))
193
193
self ._append (self .messages , message , headers )
194
194
195
195
def reset (self , count = 1 ):
@@ -207,15 +207,15 @@ def await(self, timeout=10):
207
207
return self .latch .await (timeout )
208
208
209
209
def print_state (self , hdr = "" , full = False ):
210
- print hdr ,
211
- print '#messages:' , len (self .messages ),
212
- print '#errors:' , len (self .errors ),
213
- print '#receipts:' , len (self .receipts ),
214
- print 'Remaining count:' , self .latch .get_count ()
210
+ print ( hdr )
211
+ print ( '#messages: {}' . format ( len (self .messages )))
212
+ print ( '#errors: {} ' , len (self .errors ))
213
+ print ( '#receipts: {}' . format ( len (self .receipts ))
214
+ print ( 'Remaining count: {}' . format ( self .latch .get_count ()) )
215
215
if full :
216
- if len (self .messages ) != 0 : print 'Messages:' , self .messages
217
- if len (self .errors ) != 0 : print 'Messages:' , self .errors
218
- if len (self .receipts ) != 0 : print 'Messages:' , self .receipts
216
+ if len (self .messages ) != 0 : print ( 'Messages: {}' . format ( self .messages ))
217
+ if len (self .errors ) != 0 : print ( 'Messages: {}' . format ( self .errors ))
218
+ if len (self .receipts ) != 0 : print ( 'Messages: {}' . format ( self .receipts ))
219
219
220
220
class Latch (object ):
221
221
0 commit comments