84 lines
3.5 KiB
Erlang
84 lines
3.5 KiB
Erlang
%% This Source Code Form is subject to the terms of the Mozilla Public
|
|
%% License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
|
|
%%
|
|
%% Copyright (c) 2007-2025 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries. All rights reserved.
|
|
%%
|
|
|
|
-define(HEADER_ACCEPT_VERSION, "accept-version").
|
|
-define(HEADER_ACK, "ack").
|
|
-define(HEADER_AMQP_MESSAGE_ID, "amqp-message-id").
|
|
-define(HEADER_APP_ID, "app-id").
|
|
-define(HEADER_AUTO_DELETE, "auto-delete").
|
|
-define(HEADER_CONTENT_ENCODING, "content-encoding").
|
|
-define(HEADER_CONTENT_LENGTH, "content-length").
|
|
-define(HEADER_CONTENT_TYPE, "content-type").
|
|
-define(HEADER_CORRELATION_ID, "correlation-id").
|
|
-define(HEADER_DESTINATION, "destination").
|
|
-define(HEADER_DURABLE, "durable").
|
|
-define(HEADER_EXPIRATION, "expiration").
|
|
-define(HEADER_EXCLUSIVE, "exclusive").
|
|
-define(HEADER_HEART_BEAT, "heart-beat").
|
|
-define(HEADER_HOST, "host").
|
|
-define(HEADER_ID, "id").
|
|
-define(HEADER_LOGIN, "login").
|
|
-define(HEADER_MESSAGE_ID, "message-id").
|
|
-define(HEADER_PASSCODE, "passcode").
|
|
-define(HEADER_PERSISTENT, "persistent").
|
|
-define(HEADER_PREFETCH_COUNT, "prefetch-count").
|
|
-define(HEADER_X_STREAM_OFFSET, "x-stream-offset").
|
|
-define(HEADER_X_STREAM_FILTER, "x-stream-filter").
|
|
-define(HEADER_X_STREAM_MATCH_UNFILTERED, "x-stream-match-unfiltered").
|
|
-define(HEADER_PRIORITY, "priority").
|
|
-define(HEADER_X_PRIORITY, "x-priority").
|
|
-define(HEADER_RECEIPT, "receipt").
|
|
-define(HEADER_REDELIVERED, "redelivered").
|
|
-define(HEADER_REPLY_TO, "reply-to").
|
|
-define(HEADER_SERVER, "server").
|
|
-define(HEADER_SESSION, "session").
|
|
-define(HEADER_SUBSCRIPTION, "subscription").
|
|
-define(HEADER_TIMESTAMP, "timestamp").
|
|
-define(HEADER_TRANSACTION, "transaction").
|
|
-define(HEADER_TYPE, "type").
|
|
-define(HEADER_USER_ID, "user-id").
|
|
-define(HEADER_VERSION, "version").
|
|
-define(HEADER_X_DEAD_LETTER_EXCHANGE, "x-dead-letter-exchange").
|
|
-define(HEADER_X_DEAD_LETTER_ROUTING_KEY, "x-dead-letter-routing-key").
|
|
-define(HEADER_X_EXPIRES, "x-expires").
|
|
-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").
|
|
-define(HEADER_X_QUEUE_TYPE, "x-queue-type").
|
|
-define(HEADER_X_STREAM_FILTER_SIZE_BYTES, "x-stream-filter-size-bytes").
|
|
|
|
-define(MESSAGE_ID_SEPARATOR, "@@").
|
|
|
|
-define(HEADERS_NOT_ON_SEND, [?HEADER_MESSAGE_ID]).
|
|
|
|
-define(TEMP_QUEUE_ID_PREFIX, "/temp-queue/").
|
|
|
|
-define(HEADER_ARGUMENTS, [
|
|
?HEADER_X_DEAD_LETTER_EXCHANGE,
|
|
?HEADER_X_DEAD_LETTER_ROUTING_KEY,
|
|
?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,
|
|
?HEADER_X_QUEUE_TYPE,
|
|
?HEADER_X_STREAM_FILTER_SIZE_BYTES
|
|
]).
|
|
|
|
-define(HEADER_PARAMS, [
|
|
?HEADER_AUTO_DELETE,
|
|
?HEADER_DURABLE,
|
|
?HEADER_EXCLUSIVE,
|
|
?HEADER_PERSISTENT
|
|
]).
|