diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-08-04 16:04:10 +0100 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-08-04 16:04:10 +0100 |
| commit | 0762020478b6b4e196d61b2e9bc03abe33cd02a5 (patch) | |
| tree | 98d549a88bf19be82ee97092017c4b9e3b60c480 /src | |
| parent | fbab5e9e4950211cbe30365a303687b2935a3eb6 (diff) | |
| download | rabbitmq-server-git-0762020478b6b4e196d61b2e9bc03abe33cd02a5.tar.gz | |
Removed some references to realms
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 10 | ||||
| -rw-r--r-- | src/rabbit_control.erl | 7 |
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 |
