#NEWLINE# def TryMerge( self , d ) : #NEWLINE# #INDENT# while 1 : #NEWLINE# #INDENT# tt = d . getVarInt32 ( ) #NEWLINE# if ( d == 12 ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# if ( tt == 18 ) : #NEWLINE# #INDENT# self . set_queue_name ( d . getPrefixedString ( ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# if ( tt == 25 ) : #NEWLINE# #INDENT# self . set_bucket_refill_per_second ( d . getDouble ( ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# if ( tt == 33 ) : #NEWLINE# #INDENT# self . set_bucket_capacity ( d . getDouble ( ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# if ( tt == 42 ) : #NEWLINE# #INDENT# self . set_user_specified_rate ( d . getPrefixedString ( ) ) #NEWLINE# continue #NEWLINE# #UNINDENT# if ( tt == 0 ) : #NEWLINE# #INDENT# raise ProtocolBuffer . ProtocolBufferDecodeError #NEWLINE# #UNINDENT# d . skipData ( tt )