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

Support x-stream-max-segment-size-bytes in STOMP plugin 

To be able to set the max segment size of the created
stream when using a "/queue/<name>" destination.
This commit is contained in:
Arnaud Cogoluègnes 2023-03-14 13:48:56 +01:00
parent e8ef88fb22
commit 889a63493d
No known key found for this signature in database
GPG Key ID: D5C8C4DFAD43AFA8
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbitmq_stomp/include/rabbit_stomp_headers.hrl vendored
View File

@ -45,6 +45,7 @@
-define(HEADER_X_MAX_LENGTH, "x-max-length").
-define(HEADER_X_MAX_AGE, "x-max-age").
-define(HEADER_X_MAX_LENGTH_BYTES, "x-max-length-bytes").
-define(HEADER_X_STREAM_MAX_SEGMENT_SIZE_BYTES, "x-stream-max-segment-size-bytes").
-define(HEADER_X_MAX_PRIORITY, "x-max-priority").
-define(HEADER_X_MESSAGE_TTL, "x-message-ttl").
-define(HEADER_X_QUEUE_NAME, "x-queue-name").
@ -62,6 +63,7 @@
?HEADER_X_EXPIRES,
?HEADER_X_MAX_LENGTH,
?HEADER_X_MAX_AGE,
?HEADER_X_STREAM_MAX_SEGMENT_SIZE_BYTES,
?HEADER_X_MAX_LENGTH_BYTES,
?HEADER_X_MAX_PRIORITY,
?HEADER_X_MESSAGE_TTL,

3
deps/rabbitmq_stomp/src/rabbit_stomp_util.erl vendored
View File

@ -292,6 +292,9 @@ build_argument(?HEADER_X_MESSAGE_TTL, Val) ->
build_argument(?HEADER_X_MAX_AGE, Val) ->
{list_to_binary(?HEADER_X_MAX_AGE), longstr,
list_to_binary(string:strip(Val))};
build_argument(?HEADER_X_STREAM_MAX_SEGMENT_SIZE_BYTES, Val) ->
{list_to_binary(?HEADER_X_STREAM_MAX_SEGMENT_SIZE_BYTES), long,
list_to_integer(string:strip(Val))};
build_argument(?HEADER_X_QUEUE_TYPE, Val) ->
{list_to_binary(?HEADER_X_QUEUE_TYPE), longstr,
list_to_binary(string:strip(Val))}.