summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authorMichael Bridgen <mikeb@lshift.net>2009-10-05 15:31:53 +0100
committerMichael Bridgen <mikeb@lshift.net>2009-10-05 15:31:53 +0100
commite205a1f1873b19f9dfb4ec934da1b4ee91e461a2 (patch)
tree25f878eaf5a22fd1983a48cb09002a70ea631ab5 /include
parent88d5f01b0241679fed1b1032dfde1d4760eaeb9d (diff)
parent1ff98eb5204ee7edda8b85d74667e3d31e4bc5ac (diff)
downloadrabbitmq-server-git-e205a1f1873b19f9dfb4ec934da1b4ee91e461a2.tar.gz
Merge from default. Resolved some conflicts due to bool->boolean in
type specs, and a bad automerge in rabbit_reader.erl.
Diffstat (limited to 'include')
-rw-r--r--include/rabbit.hrl23
-rw-r--r--include/rabbit_framing_spec.hrl2
2 files changed, 15 insertions, 10 deletions
diff --git a/include/rabbit.hrl b/include/rabbit.hrl
index 61cedc440a..c94965f9ee 100644
--- a/include/rabbit.hrl
+++ b/include/rabbit.hrl
@@ -64,8 +64,11 @@
-record(basic_message, {exchange_name, routing_key, content, persistent_key}).
+-record(ssl_socket, {tcp, ssl}).
-record(delivery, {mandatory, immediate, txn, sender, message}).
+-record(amqp_error, {name, explanation, method = none}).
+
%%----------------------------------------------------------------------------
-ifdef(use_specs).
@@ -74,7 +77,8 @@
-type(maybe(T) :: T | 'none').
-type(erlang_node() :: atom()).
--type(socket() :: port()).
+-type(ssl_socket() :: #ssl_socket{}).
+-type(socket() :: port() | ssl_socket()).
-type(thunk(T) :: fun(() -> T)).
-type(info_key() :: atom()).
-type(info() :: {info_key(), any()}).
@@ -99,14 +103,14 @@
read :: regexp()}).
-type(amqqueue() ::
#amqqueue{name :: queue_name(),
- durable :: bool(),
- auto_delete :: bool(),
+ durable :: boolean(),
+ auto_delete :: boolean(),
arguments :: amqp_table(),
pid :: maybe(pid())}).
-type(exchange() ::
#exchange{name :: exchange_name(),
type :: exchange_type(),
- durable :: bool(),
+ durable :: boolean(),
arguments :: amqp_table()}).
-type(binding() ::
#binding{exchange_name :: exchange_name(),
@@ -136,14 +140,14 @@
persistent_key :: maybe(pkey())}).
-type(message() :: basic_message()).
-type(delivery() ::
- #delivery{mandatory :: bool(),
- immediate :: bool(),
+ #delivery{mandatory :: boolean(),
+ immediate :: boolean(),
txn :: maybe(txn()),
sender :: pid(),
message :: message()}).
%% this really should be an abstract type
-type(msg_id() :: non_neg_integer()).
--type(msg() :: {queue_name(), pid(), msg_id(), bool(), message()}).
+-type(msg() :: {queue_name(), pid(), msg_id(), boolean(), message()}).
-type(listener() ::
#listener{node :: erlang_node(),
protocol :: atom(),
@@ -151,7 +155,10 @@
port :: non_neg_integer()}).
-type(not_found() :: {'error', 'not_found'}).
-type(routing_result() :: 'routed' | 'unroutable' | 'not_delivered').
-
+-type(amqp_error() ::
+ #amqp_error{name :: atom(),
+ explanation :: string(),
+ method :: atom()}).
-endif.
%%----------------------------------------------------------------------------
diff --git a/include/rabbit_framing_spec.hrl b/include/rabbit_framing_spec.hrl
index f45fa6caf4..a78c230167 100644
--- a/include/rabbit_framing_spec.hrl
+++ b/include/rabbit_framing_spec.hrl
@@ -50,8 +50,6 @@
%% TODO: make this more precise
-type(amqp_method_name() :: atom()).
-type(channel_number() :: non_neg_integer()).
-%% TODO: make this more precise
--type(amqp_error() :: {bool(), non_neg_integer(), binary()}).
-type(resource_name() :: binary()).
-type(routing_key() :: binary()).
-type(username() :: binary()).