Fix docs.

[pithos] / pithos / lib / queue.py

diff --git a/pithos/lib/queue.py b/pithos/lib/queue.py
index 0cfe830..a1c08b8 100755 (executable)
--- a/pithos/lib/queue.py
+++ b/pithos/lib/queue.py
@@ -33,8 +33,10 @@
 
 import pika
 import json
+import uuid
 
 from urlparse import urlparse
+from time import time
 
 
 def exchange_connect(exchange, vhost='/'):
@@ -89,3 +91,18 @@ def queue_callback(conn, queue, cb):
 def queue_start(conn):
     connection, channel, exchange = conn
     channel.start_consuming()
+
+class Receipt(object):
+    def __init__(self, client, user, resource, value, details=None):
+        self.eventVersion = 1
+        self.id = str(uuid.uuid4())
+        self.timestamp = int(time() * 1000)
+        self.clientId = client
+        self.userId = user
+        self.resource = resource
+        self.value = value
+        if details:
+            self.details = details
+    
+    def format(self):
+        return self.__dict__