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

Don't try to parse every routing key as an integer 

References #37.
This commit is contained in:
Michael Klishin 2018-08-20 19:29:42 +03:00
parent e132a0a865
commit 0faf2ba272
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbitmq_consistent_hash_exchange/src/rabbit_exchange_type_consistent_hash.erl vendored
View File

@ -256,9 +256,6 @@ jump_consistent_hash(_Key, 1) ->
0; 0;
jump_consistent_hash(KeyList, NumberOfBuckets) when is_list(KeyList) -> jump_consistent_hash(KeyList, NumberOfBuckets) when is_list(KeyList) ->
jump_consistent_hash(hd(KeyList), NumberOfBuckets); jump_consistent_hash(hd(KeyList), NumberOfBuckets);
jump_consistent_hash(KeyBin, NumberOfBuckets) when is_binary(KeyBin) ->
Key = rabbit_data_coercion:to_integer(KeyBin),
jump_consistent_hash(Key, NumberOfBuckets);
jump_consistent_hash(Key, NumberOfBuckets) when is_integer(Key) -> jump_consistent_hash(Key, NumberOfBuckets) when is_integer(Key) ->
SeedState = rand:seed_s(exs1024s, {Key, Key, Key}), SeedState = rand:seed_s(exs1024s, {Key, Key, Key}),
jump_consistent_hash_value(-1, 0, NumberOfBuckets, SeedState); jump_consistent_hash_value(-1, 0, NumberOfBuckets, SeedState);