Revision 73673127 snf-pithos-backend/pithos/backends/lib/rabbitmq/queue.py

b/snf-pithos-backend/pithos/backends/lib/rabbitmq/queue.py
44 44
        self.conn = exchange_connect(exchange)
45 45
        self.client_id = params['client_id']
46 46
    
47
    def send(self, message_key, user, resource, value, details):
48
        body = Receipt(self.client_id, user, resource, value, details).format()
47
    def send(self, message_key, user, instance, resource, value, details):
48
        body = Receipt(self.client_id, user, instance, resource, value, details).format()
49 49
        exchange_send(self.conn, message_key, body)
50 50
    
51 51
    def close(self):

Also available in: Unified diff