summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2010-01-19 16:53:42 +0000
committerMatthew Sackman <matthew@lshift.net>2010-01-19 16:53:42 +0000
commit51c879d3069024a8264a61dd4037f914d10cb2fe (patch)
tree53406e6bdd68d1c59cef6b00e9b815a75037db47 /src
parent8d1b348f0aad58bbf492603090800d6a15190bb3 (diff)
downloadrabbitmq-server-git-51c879d3069024a8264a61dd4037f914d10cb2fe.tar.gz
Added behaviour for msg_store_index and tidied includes, and updated makefile appropriately. Good lord it'd be nice if erlang did proper build dependencies...
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_msg_store_ets_index.erl5
-rw-r--r--src/rabbit_msg_store_index.erl46
2 files changed, 50 insertions, 1 deletions
diff --git a/src/rabbit_msg_store_ets_index.erl b/src/rabbit_msg_store_ets_index.erl
index e8d596f9c5..f4814cd1ff 100644
--- a/src/rabbit_msg_store_ets_index.erl
+++ b/src/rabbit_msg_store_ets_index.erl
@@ -30,12 +30,15 @@
%%
-module(rabbit_msg_store_ets_index).
+
+-behaviour(rabbit_msg_store_index).
+
-export([init/1, lookup/2, insert/2, update/2, update_fields/3, delete/2,
delete_by_file/2, terminate/1]).
-define(MSG_LOC_NAME, rabbit_msg_store_ets_index).
--include("rabbit_msg_store.hrl").
+-include("rabbit_msg_store_index.hrl").
init(_Dir) ->
ets:new(?MSG_LOC_NAME, [set, public, {keypos, #msg_location.msg_id}]).
diff --git a/src/rabbit_msg_store_index.erl b/src/rabbit_msg_store_index.erl
new file mode 100644
index 0000000000..9d899d8a70
--- /dev/null
+++ b/src/rabbit_msg_store_index.erl
@@ -0,0 +1,46 @@
+%% The contents of this file are subject to the Mozilla Public License
+%% Version 1.1 (the "License"); you may not use this file except in
+%% compliance with the License. You may obtain a copy of the License at
+%% http://www.mozilla.org/MPL/
+%%
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the
+%% License for the specific language governing rights and limitations
+%% under the License.
+%%
+%% The Original Code is RabbitMQ.
+%%
+%% The Initial Developers of the Original Code are LShift Ltd,
+%% Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd.
+%%
+%% Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd,
+%% Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd
+%% are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial
+%% Technologies LLC, and Rabbit Technologies Ltd.
+%%
+%% Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift
+%% Ltd. Portions created by Cohesive Financial Technologies LLC are
+%% Copyright (C) 2007-2009 Cohesive Financial Technologies
+%% LLC. Portions created by Rabbit Technologies Ltd are Copyright
+%% (C) 2007-2009 Rabbit Technologies Ltd.
+%%
+%% All Rights Reserved.
+%%
+%% Contributor(s): ______________________________________.
+%%
+
+-module(rabbit_msg_store_index).
+
+-export([behaviour_info/1]).
+
+behaviour_info(callbacks) ->
+ [{init, 1},
+ {lookup, 2},
+ {insert, 2},
+ {update, 2},
+ {update_fields, 3},
+ {delete, 2},
+ {delete_by_file, 2},
+ {terminate, 1}];
+behaviour_info(_Other) ->
+ undefined.