[rhmessaging-commits] rhmessaging commits: r4052 - store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb.

[rhmessaging-commits at lists.jboss.org]

Author: rgemmell
Date: 2010-06-25 11:13:09 -0400 (Fri, 25 Jun 2010)
New Revision: 4052

Modified:
   store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
Log:
Add comment with table schemas


Modified: store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
===================================================================
--- store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java	2010-06-25 11:59:53 UTC (rev 4051)
+++ store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java	2010-06-25 15:13:09 UTC (rev 4052)
@@ -114,6 +114,31 @@
     private Database _exchangeDb;
     private Database _queueDb;
 
+    /* =======
+     * Schema:
+     * =======
+     * 
+     * Queue:
+     * name(AMQShortString) - name(AMQShortString), owner(AMQShortString), 
+     *                        arguments(FieldTable encoded as binary), exclusive (boolean)
+     *
+     * Exchange:
+     * name(AMQShortString) - name(AMQShortString), typeName(AMQShortString), autodelete (boolean)
+     *
+     * Binding:
+     * exchangeName(AMQShortString), queueName(AMQShortString), routingKey(AMQShortString),
+     *                                            arguments (FieldTable encoded as binary) - 0 (zero)
+     *
+     * QueueEntry:
+     * queueName(AMQShortString), messageId (long) - 0 (zero)
+     *
+     * Message (MetaData):
+     * messageId (long) - bodySize (integer), metaData (MessageMetaData encoded as binary)
+     *
+     * Message (Content):
+     * messageId (long), byteOffset (integer) - dataLength(integer), data(binary);
+     */
+
     private LogSubject _logSubject;
 
     private final AtomicLong _messageId = new AtomicLong(0);