root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

more unit tests for the destination parser

This commit is contained in:
Rob Harrop 2010-10-01 14:49:23 +01:00
parent e492226a77
commit 68372b7e39
2 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbitmq_stomp/src/rabbit_stomp_destination_parser.erl vendored
View File

@ -43,8 +43,8 @@ parse_destination(?TOPIC_PREFIX ++ Rest) ->
parse_simple_destination(topic, Rest);
parse_destination(?EXCHANGE_PREFIX ++ Rest) ->
case parse_content(Rest) of
[Name] -> {exchange, {Name, undefined}};
[Name, Pattern] -> {exchange, {Name, Pattern}};
[Name] -> {ok, {exchange, {Name, undefined}}};
[Name, Pattern] -> {ok, {exchange, {Name, Pattern}}};
_ -> {error, {invalid_destination, exchange, Rest}}
end;
parse_destination(_) ->
@ -52,7 +52,7 @@ parse_destination(_) ->
parse_simple_destination(Type, Content) ->
case parse_content(Content) of
[Name] -> {Type, Name};
[Name] -> {ok, {Type, Name}};
_ -> {error, {invalid_destination, Type, Content}}
end.

26
deps/rabbitmq_stomp/test/rabbit_stomp_test_destination_parser.erl vendored
View File

@ -23,16 +23,16 @@
-include_lib("eunit/include/eunit.hrl").
valid_queue_test() ->
{queue, "test"} = parse_destination("/queue/test").
{ok, {queue, "test"}} = parse_destination("/queue/test").
valid_topic_test() ->
{topic, "test"} = parse_destination("/topic/test").
{ok, {topic, "test"}} = parse_destination("/topic/test").
valid_exchange_test() ->
{exchange, {"test", undefined}} = parse_destination("/exchange/test").
{ok, {exchange, {"test", undefined}}} = parse_destination("/exchange/test").
valid_exchange_with_pattern_test() ->
{exchange, {"test", "pattern"}} =
{ok, {exchange, {"test", "pattern"}}} =
parse_destination("/exchange/test/pattern").
queue_with_no_name_test() ->
@ -52,7 +52,23 @@ topic_with_no_name_slash_test() ->
{error, {invalid_destination, topic, "/"}} = parse_destination("/topic/").
exchange_with_no_name_slash_test() ->
{error, {invalid_destination, exchange, "/"}} = parse_destination("/exchange/").
{error, {invalid_destination, exchange, "/"}} =
parse_destination("/exchange/").
queue_with_invalid_name_test() ->
{error, {invalid_destination, queue, "/foo/bar"}} =
parse_destination("/queue/foo/bar").
topic_with_invalid_name_test() ->
{error, {invalid_destination, topic, "/foo/bar"}} =
parse_destination("/topic/foo/bar").
exchange_with_invalid_name_test() ->
{error, {invalid_destination, exchange, "/foo/bar/baz"}} =
parse_destination("/exchange/foo/bar/baz").
unknown_destination_test() ->
{error, unknown_destination} = parse_destination("/blah/boo").
parse_destination(Destination) ->
rabbit_stomp_destination_parser:parse_destination(Destination).