def send_reply(exchange, req, msg, producer=None, retry=False, retry_policy=None, **props):
 producer.publish(msg, exchange=exchange, retry=retry, retry_policy=retry_policy, **dict({'routing_key': req.properties['reply_to'], 'correlation_id': req.properties.get('correlation_id'), 'serializer': serializers.type_to_name[req.content_type], 'content_encoding': req.content_encoding}, **props))

def send_reply ( exchange , req , msg , producer = None , retry = False , retry_policy = None , ** props ) : producer . publish ( msg , exchange = exchange , retry = retry , retry_policy = retry_policy , ** dict ( { 'routing_key' : req . properties [ 'reply_to' ] , 'correlation_id' : req . properties . get ( 'correlation_id' ) , 'serializer' : serializers . type_to_name [ req . content_type ] , 'content_encoding' : req . content_encoding } , ** props ) )
send reply for request .