Commiting some crufty bits of initial persistence attempts for poster…

…ity.
lgastako · Mar 7, 2009 · 70f509f · 70f509f
1 parent 790e3fc
commit 70f509f
Show file tree

Hide file tree

Showing 3 changed files with 44 additions and 3 deletions.
diff --git a/erqnesia.erl b/erqnesia.erl
@@ -1,5 +1,6 @@
 -module(erqnesia).
--export([create_database/0, start/0]).
+-include("queues.hrl").
+-export([create_database/0, start/0, enqueue/3]).
 
 %% Run this once to setup the database.  
 %% TODO: Auto detect database existence and create it automatically.
@@ -19,8 +20,21 @@ create_schema() ->
 
 create_tables() ->
     mnesia:delete_table(queues),
-    mnesia:create_table(queues, 
+    mnesia:create_table(message,
                         [
                          {disc_copies, [node()]},
-                         {type, ordered_set}
+                         {type, ordered_set},
+                         {attributes, record_info(fields, message)}
                         ]).
+
+enqueue(QueueName, Data, Flags) ->
+    mnesia:transaction(fun() -> 
+                               mnesia:write(#message{queue_name=QueueName,
+                                                     data=Data,
+                                                     flags=Flags}) 
+                       end).
+
+%% dequeue(QueueName) ->
+%%      mnesia:transaction(fun() ->
+%%                                 Key = mnesia:first(messages),
+
diff --git a/journal.erl b/journal.erl
@@ -0,0 +1,26 @@
+-module(journal).
+-export(...).
+
+start_journal_for_queue_path(QueuePath) ->
+    spawn(fun() -> manage_journal(QueuePath) end).
+
+manage_journal(QueuePath) ->
+    receive
+%%         {cmd, open} -> do_open(QueuePath);
+%%         {cmd, erase} -> do_erase(QueuePath);
+%%         {cmd, roll} -> do_roll(QueuePath);
+%%         {cmd, close} -> do_close(QueuePath);
+%%         {cmd, add} -> do_add(QueuePath);
+%%         {cmd, add_with_xid} -> do_add_with_xid(QueuePath);
+%%         remove
+%% remove_tentative
+%% unremove
+%% confirm ->
+
+erase(Journal) ->
+    close it and delete it.
+
+write_items(Journal, Items) ->
+    ...
+
+
diff --git a/queues.hrl b/queues.hrl
@@ -0,0 +1 @@
+-record(message, {queue_name, data, flags}).