'Send task return value and state.'

def store_result(self, task_id, result, state, traceback=None, request=None, **kwargs):

    (routing_key, correlation_id) = self.destination_for(task_id, request)
    if (not routing_key):
        return
    with self.app.amqp.producer_pool.acquire(block=True) as producer:
        producer.publish(self._to_result(task_id, state, result, traceback, request), exchange=self.exchange, routing_key=routing_key, correlation_id=correlation_id, serializer=self.serializer, retry=True, retry_policy=self.retry_policy, declare=self.on_reply_declare(task_id), delivery_mode=self.delivery_mode)
    return result
