summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorBen Hood <0x6e6562@gmail.com>2008-08-04 16:04:10 +0100
committerBen Hood <0x6e6562@gmail.com>2008-08-04 16:04:10 +0100
commit0762020478b6b4e196d61b2e9bc03abe33cd02a5 (patch)
tree98d549a88bf19be82ee97092017c4b9e3b60c480 /src
parentfbab5e9e4950211cbe30365a303687b2935a3eb6 (diff)
downloadrabbitmq-server-git-0762020478b6b4e196d61b2e9bc03abe33cd02a5.tar.gz
Removed some references to realms
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl10
-rw-r--r--src/rabbit_control.erl7
2 files changed, 4 insertions, 13 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index b02a3c0a38..426cbd7899 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -93,7 +93,7 @@ init(ProxyPid, [ReaderPid, WriterPid, Username, VHost]) ->
unacked_message_q = queue:new(),
username = Username,
virtual_host = VHost,
- most_recently_declared_queue = <<>>,
+ most_recently_declared_queue = none,
consumer_mapping = dict:new()}.
handle_message({method, Method, Content}, State) ->
@@ -168,7 +168,7 @@ return_queue_declare_ok(State, NoWait, Q) ->
{reply, Reply, NewState}
end.
-expand_queue_name_shortcut(<<>>, #ch{ most_recently_declared_queue = <<>> }) ->
+expand_queue_name_shortcut(<<>>, #ch{ most_recently_declared_queue = none }) ->
rabbit_misc:protocol_error(
not_allowed, "no previously declared queue", []);
expand_queue_name_shortcut(<<>>, #ch{ most_recently_declared_queue = MRDQ }) -> MRDQ;
@@ -176,7 +176,7 @@ expand_queue_name_shortcut(QueueNameBin, #ch{ virtual_host = VHostPath }) ->
rabbit_misc:r(VHostPath, queue, QueueNameBin).
expand_routing_key_shortcut(<<>>, <<>>,
- #ch{ most_recently_declared_queue = <<>> }) ->
+ #ch{ most_recently_declared_queue = none }) ->
rabbit_misc:protocol_error(
not_allowed, "no previously declared queue", []);
expand_routing_key_shortcut(<<>>, <<>>,
@@ -336,7 +336,7 @@ handle_method(#'basic.consume'{queue = QueueNameBin,
ConsumerMapping)}};
{error, queue_owned_by_another_connection} ->
%% The spec is silent on which exception to use
- %% here. This seems reasonable?
+ %% here. This seems reasonable?
%% FIXME: check this
rabbit_misc:protocol_error(
@@ -450,7 +450,6 @@ handle_method(#'exchange.declare'{exchange = ExchangeNameBin,
arguments = Args},
_, State = #ch{ virtual_host = VHostPath }) ->
CheckedType = rabbit_exchange:check_type(TypeNameBin),
- %% FIXME: clarify spec as per declare wrt differing realms
ExchangeName = rabbit_misc:r(VHostPath, exchange, ExchangeNameBin),
X = case rabbit_exchange:lookup(ExchangeName) of
{ok, FoundX} -> FoundX;
@@ -520,7 +519,6 @@ handle_method(#'queue.declare'{queue = QueueNameBin,
end,
Q
end,
- %% FIXME: clarify spec as per declare wrt differing realms
Q = case rabbit_amqqueue:with(
rabbit_misc:r(VHostPath, queue, QueueNameBin),
Finish) of
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl
index 12040725f9..eb24b78270 100644
--- a/src/rabbit_control.erl
+++ b/src/rabbit_control.erl
@@ -88,13 +88,6 @@ Available commands:
list_user_vhosts <UserName>
list_vhost_users <VHostPath>
- set_permissions <UserName> <VHostPath> <RealmName> [<Permission> ...]
- Permissions management. The available permissions are 'passive',
- 'active', 'write' and 'read', corresponding to the permissions
- referred to in AMQP's \"access.request\" message, or 'all' as an
- abbreviation for all defined permission flags.
- list_permissions <UserName> <VHostPath>
-
<node> should be the name of the master node of the RabbitMQ cluster. It
defaults to the node named \"rabbit\" on the local host. On a host named
\"server.example.com\", the master node will usually be rabbit@server (unless