#NEWLINE# def _add_binding( self , source , routing_key = '' , inbox_type = ACTOR_TYPE . DIRECT ) : #NEWLINE# #INDENT# source_exchange = Exchange ( ** source ) #NEWLINE# binder = self . get_binder ( inbox_type ) #NEWLINE# maybe_declare ( inbox_type , self . connection . default_channel ) #NEWLINE# binder ( exchange = source_exchange , routing_key = routing_key )