Products Downloads


French version


 

      


      


EADELIA





(B) (C)

Section for use

onStart / onStop / onError / onMessage

Syntax

BRK_GET_CONF PropertyName <result variable>

PropertyName

SpecialValue | AlphaPropertyName

SpecialValue

*BRK_NAME | *BRK_PROTOCOL | *BRK_VERSION | *BRK_IMPL

Description

This instruction gets information about the execution context of the Adelia subscriber. Each item of information is defined by a key (PropertyName parameter) and has an associated typed value (the result variable parameter).

The key can either be defined by a special value or, in the case of AlphaPropertyName, by an alphanumeric variable, an alphanumeric constant or an alphanumeric literal.


Special value key
Special valueProperty descriptionProperty type
*BRK_NAMEName of the message broker the subscriber is connected toALPHA(n)
*BRK_PROTOCOLName of the protocol used to exchange messages between the broker and subscriberALPHA(n)
*BRK_VERSIONVersion of the protocol used to exchange messages between the broker and subscriberALPHA(n)
*BRK_IMPLNative subscriber implementation identifier enabling communication between the broker and the Adelia subscriberALPHA(n)


Depending on the target message broker, these special values have the following values:

Message broker*BRK_NAME*BRK_PROTOCOL*BRK_VERSION*BRK_IMPL
KafkaKAFKAKAFKA2.8.0org.apache.kafka:kafka-clients:2.8.0
MQTT v3MQTT_BROKERMQTT3.1.1org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5
MQTT v5MQTT_BROKERMQTT5org.eclipse.paho:org.eclipse.paho.mqttv5.client:1.2.5
Nats JetsteamNATS JETSTREAMNATS JETSTREAM2.10.4io.nats:jnats:2.12.0
RabbitMQ AMQPRABBITMQAMQP0.9.1com.rabbitmq:amqp-client:5.7.3
Redis Pub/SubREDISREDIS2.6io.lettuce:lettuce-core:6.1.6.RELEASE



Alphanumeric key

When the key is alphanumeric, it can either designate a standard property present in all the Adelia subscribers or a specific property relating to the associated message broker.


Standard key

The value is an alphanumeric string representing an XPath expression and designating a property relating to a subscriber definition.

Key value Property description Property type
subconf/id Adelia subscriber identifier ALPHA(n)
subconf/startOnCreation Specifies if the Adelia subscriber needs to be started on creation BOOL
subconf/config
subconf/config Adelia subscriber configuration (exportable) N / A
subconf/config/adeliaPoolName Name of the Adelia pool used to configure DB connections in the associated EADELIA program ALPHA(n)
subconf/config/adeliaPgm
subconf/config/adeliaPgm Configuration of the EADELIA program associated with the subscriber N / A
subconf/config/adeliaPgm/objectFileName Name of the object file resulting from the generation of the associated EADELIA program ALPHA(6)
subconf/config/adeliaPgm/javaPackage Name of the Java package defined for the generation of the associated EADELIA program ALPHA(256)
subconf/config/adeliaPgm/parameters List of alphanumeric parameters passed to the associated EADELIA program during execution ALPHA(n) array
subconf/config/adeliaPgm/parameters[<index commençant à 1] Value of the <index> index parameter in the list of alphanumeric parameters passed to the associated EADELIA program during execution ALPHA(n)
subconf/config/adeliaPgm/customObjectMapper Java Bean ID defined in the beans-context.xml file, used to configure the properties to convert a JSON object to an Adelia class instance ALPHA(n)
subconf/config/brokerConfig/factory
subconf/config/brokerConfig/factory Information on the factory in charge of creating the Adelia subscriber N / A
subconf/config/brokerConfig/factory/id ID of the factory used to create the Adelia subscriber ALPHA(n)
subconf/config/brokerConfig/factory/parameters/<nom parametre> Value associated with the <parameter name> parameter passed to the associated factory during creation. The parameter name depends on the factory. The type depends on the associated factory.
adelUtils:mapKeys(subconf/config/brokerConfig/factory/parameters) List of names of parameters passed to the associated factory during creation ALPHA(n) array
adelUtils:mapValues(subconf/config/brokerConfig/factory/parameters) List of values of parameters passed to the associated factory during creation One-dimensional array. The type depends on the associated factory. The type must be the same for all parameters



Specific key

Like a standard key, its value is an alphanumeric string representing an XPath expression. A specific key is used to designate a property relating to message broker connection information and information for subscribing to the message categories the subscriber wants to handle. Each specific key therefore depends on the target broker (and the associated factory):


.  Kafka

Kafka

brokerConnection connection information

Details in Kafka documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/brokerConnection/key.deserializerJava class used to deserialize the message key.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/value.deserializerJava class used to deserialize the message payload.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/bootstrap.servers

List of Kafka broker server URIs used for connection.

ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/fetch.min.bytes

Minimum amount of data the server must return for a fetch request.

NUM_BIN_4

subconf/config/brokerConfig/brokerConnection/group.id

Unique string identifying the consumer group this subscriber belongs to.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/heartbeat.interval.ms

Interval in milliseconds between heartbeat checks to the consumer group coordinator to indicate that a subscriber is active and connected.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/max.partition.fetch.bytes

Maximum amount of data per partition that the server will return to the subscriber

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/session.timeout.ms

Maximum time in milliseconds during which a consumer in a consumer group can be out of contact with a broker before being considered idle and before rebalancing is initiated among the active consumers in the group.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/allow.auto.create.topics

Used to allow automatic topic creation on the broker when subscribing to a topic.

BOOL
subconf/config/brokerConfig/brokerConnection/auto.offset.reset

Specifies what to do when there is no initial offset in Kafka or if the current offset no longer exists on the server (e.g. because the data has been deleted).

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/client.dns.lookup

Controls how the subscriber uses DNS lookups.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/connections.max.idle.ms

Closes idle connections after the number of milliseconds specified by this configuration.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/default.api.timeout.ms

Wait time (in milliseconds) for client APIs. This configuration is used as the default timeout for all client operations that do not specify a timeout parameter.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/enable.auto.commit

If true, the consumer's offset will be periodically committed in the background.

BOOL
subconf/config/brokerConfig/brokerConnection/exclude.internal.topics

Indicates whether internal topics matching a subscription pattern should be excluded from the subscription. It is always possible to explicitly subscribe to an internal topic.

BOOL
subconf/config/brokerConfig/brokerConnection/fetch.max.bytesMaximum amount of data the server should return for a fetch request.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/group.instance.id

Unique identifier of the consumer instance provided by the end user.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/isolation.level

Controls how to read messages written transactionally.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/max.poll.interval.ms

Maximum delay between invocations of poll() when using consumer group management.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/max.poll.records

Maximum number of records returned in a single call to poll().

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/partition.assignment.strategy

List of class names or class types, ordered by preference, of supported partition assignment strategies that the client will use to distribute partition ownership amongst consumer instances when group management is used.

ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/receive.buffer.bytes

Size of the TCP receive buffer (SO_RCVBUF) to use when reading data.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/request.timeout.ms

Maximum amount of time the client will wait for the response from a request.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/security.protocol

Protocol used to communicate with brokers.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/send.buffer.bytes

Size of the TCP send buffer (SO_SNDBUF) to use when sending data.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/socket.connection.setup.timeout.max.ms

Maximum amount of time the client will wait for the socket connection to be established.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/socket.connection.setup.timeout.ms

Amount of time the client will wait for the socket connection to be established.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/ssl.enabled.protocols

List of protocols enabled for SSL connections.

ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/ssl.keystore.type

File format of the keystore file.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.protocol

SSL protocol used to generate the SSLContext.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.provider

Name of the security provider used for SSL connections.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.truststore.type

File format of the Truststore file.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/auto.commit.interval.ms

Frequency in milliseconds with which the consumer offsets are auto-committed to Kafka if enable.auto.commit is set to "true".

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/check.crcs

Automatically checks the CRC32 of the messages consumed.

BOOL
subconf/config/brokerConfig/brokerConnection/client.id

ID string to pass to the server when making requests.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/client.rack

Rack identifier for this client. This can be any string value indicating the physical location of this client. It corresponds to the "broker.rack" broker configuration.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/fetch.max.wait.ms

Maximum amount of time the server will block before answering the fetch request if there is not sufficient data to immediately satisfy the requirement given by "fetch.min.bytes".

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/interceptor.classes

List of classes to use as interceptors. Implementing the org.apache.kafka.clients.consumer.ConsumerInterceptor interface allows you to intercept (and possibly mutate) records received by the consumer.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metadata.max.age.ms

Period of time in milliseconds after which we force a metadata refresh even if we have not seen any partition leadership changes to proactively discover any new brokers or partitions.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/metric.reporters

List of classes to use as metrics reporters.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metrics.num.samples

Number of samples maintained to compute metrics.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/metrics.recording.level

Highest recording level for metrics.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metrics.sample.window.ms

Window of time during which a metrics sample is computed.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/reconnect.backoff.max.ms

Maximum amount of time in milliseconds to wait when reconnecting to a broker that has repeatedly failed to connect.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/reconnect.backoff.ms

Base amount of time to wait before attempting to reconnect to a given host.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/retry.backoff.ms

Amount of time to wait before attempting to retry a failed request to a given topic partition.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/security.providers

List of configurable creator classes each returning a provider implementing security algorithms.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/schema.registry.url

Schema Registry instance URL.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/specific.avro.reader

Tells Kafka/Schema Registry to use a specific Avro type (user type in this case, resulting from the Avro generation of an Adelia class), otherwise Kafka will wait until the GenericRecord is used for the topic.

BOOL

Kafka

subscribeTopic subscription information.

Details in Spring Kafka documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/patternSubscription model defining a topic pattern to subscribe with.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topicsList of names of topics to subscribe to.Tableau d'ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/partitionsList of <topic, partition number> pairs to subscribe to.N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/partitions)Size of the list of <topic, partition number> pairs to subscribe to.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/partitions[<index commençant à 1>]/topicValue of the "topic" field of the <index> index pair in the list of <topic, partition number> pairs to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/partitions[<index commençant à 1>]/partitionValue of the "partition number" field of the <index> index pair in the list of <topic, partition number> pairs to subscribe to.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/ackModeMessage consumption and acknowledgment mode.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/ackTimeTime in milliseconds since the last acknowledgment after which message acknowledgment (offset commit) will be initiated. Taken into account if ackMode is "TIME" or "COUNT_TIME".NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/ackCountThe number of messages (records) pending commit after the last acknowledgment after which message acknowledgment will be initiated. Taken into account if ackMode is "COUNT" or "COUNT_TIME".NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/typeMsgHandlingMessage consumption type (one by one or by batch) when ackMode is "MANUAL" or "MANUAL_IMMEDIATE".ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pollTimeoutWait time passed in the poll() function.NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/commitLogLevel

Logging level of logs relating to offset commits.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/missingTopicsFatal

Specifies if the subscriber needs to start if the configured topic(s) are not present on the broker.

BOOL
subconf/config/brokerConfig/subscribeTopic/onlyLogRecordMetadata

Set to false to log the whole consumer record instead of simply topic-partition@offset.

BOOL
subconf/config/brokerConfig/subscribeTopic/stopImmediate

When the subscriber is stopped, allows handling to be stopped after the current message (true) instead of after handling all the messages returned by the previous call to poll() (false).

BOOL


. MQTT v3

MQTT v3

brokerConnection connection information

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/brokerConnection/automaticReconnect

Specifies if the client will automatically try to reconnect to the server if the connection is lost.

BOOL
subconf/config/brokerConfig/brokerConnection/reconnectCloseTimeoutSuccessful reconnection attempt wait time before definitively closing the subscriber.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/cleanSession

Specifies if the client and server need to remember the client's state when reconnecting.

BOOL
subconf/config/brokerConfig/brokerConnection/connectionTimeout

Connection timeout value. This value, measured in seconds, defines the maximum time the client will wait for network connection to the MQTT server to be established.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/keepAliveInterval

"Keep alive" interval. This value, measured in seconds, defines the maximum time interval between sent or received messages. This enables the client to detect if the server is no longer available, without waiting for TCP/IP timeout.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/maxInflight

Maximum number of messages the broker can send without receiving an acknowledgment.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/mqttVersionSets which version of the MQTT v3 protocol to use (3.1 or 3.1.1).ALPHA(n)
subconf/config/brokerConfig/brokerConnection/serverURIs

List of one or more MQTT server URIs the client can connect to.

ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/userName

Username to use to connect.

ALPHA(n)
brokerConnection/will
subconf/config/brokerConfig/brokerConnection/will

"Last Will and Testament" (LWT) message for connection.

N / A
subconf/config/brokerConfig/brokerConnection/will/topicLWT topic.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/payloadLWT message payload.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/qosQuality of service level for publishing LWT messages.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/will/retainedSpecifies if the LWT message needs to be retained.BOOL

MQTT v3

subscribeTopic subscription information.

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/clientId

Client ID.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistanceMessage persistence mechanism.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistantFileDirectory

Message storage directory. Taken into account when "persistence" is "file".

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/manualAcks

Specifies if message acknowledgment is automatic or manual.

BOOL
subconf/config/brokerConfig/subscribeTopic/timeToWait

Maximum time to wait for an action with the broker to finish.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/topics

List of information about topics to subscribe to.

N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/topics)Size of the list of information about topics to subscribe to.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/topicFilterName of the <index> index topic in the list of information about topics to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/qosQuality of service level for receiving messages from the <index> index topic in the list of information about topics to subscribe to.NUM_BIN_4


. MQTT v5

MQTT v5

brokerConnection connection information

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/brokerConnection/authDataAuthentication data.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/authMethodAuthentication method.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/automaticReconnect

Specifies if the client will automatically try to reconnect to the server if the connection is lost.

BOOL
subconf/config/brokerConfig/brokerConnection/automaticReconnectMinDelay

Minimum number of seconds to wait before attempting to reconnect automatically.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/automaticReconnectMaxDelayMaximum number of seconds to wait before attempting to reconnect automatically.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/reconnectCloseTimeoutSuccessful reconnection attempt wait time before definitively closing the subscriber.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/cleanStart

Specifies if the client and server need to remember the session state when restarting and reconnecting.

BOOL
subconf/config/brokerConfig/brokerConnection/connectionTimeout

Connection timeout value. This value, measured in seconds, defines the maximum time the client will wait for network connection to the MQTT server to be established.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/httpsHostnameVerificationEnabledEnables host verification during an HTTPS connection.BOOL
subconf/config/brokerConfig/brokerConnection/keepAliveInterval

"Keep alive" interval. This value, measured in seconds, defines the maximum time interval between sent or received messages. This enables the client to detect if the server is no longer available, without waiting for TCP/IP timeout.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/maximumPacketSize

Maximum packet size.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/maxReconnectDelay

Maximum wait time between reconnect attempts.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/receiveMaximum

Maximum number of received messages This value represents the maximum number of QoS 1 and QoS 2 messages the client is ready to process simultaneously.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/requestProblemInfo

Sets the information request indicator relating to problems encountered in the communication protocol.

BOOL
subconf/config/brokerConfig/brokerConnection/requestResponseInfo

Sets the request response information indicator.

BOOL
subconf/config/brokerConfig/brokerConnection/serverURIs

List of one or more MQTT server URIs the client can connect to.

ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/sessionExpiryInterval

Session expiry interval. This value, measured in seconds, defines the maximum time the broker will maintain the session once the client has disconnected. Clients should only connect with a long session expiry interval if they intend to connect to the server later.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/sSLProperties

Connection SSL properties (in the form of a hash table).

N / A
adelUtils:mapKeys(subconf/config/brokerConfig/brokerConnection/sSLProperties)List of connection SSL property names.ALPHA(n) array
adelUtils:mapValues(subconf/config/brokerConfig/brokerConnection/sSLProperties)List of connection SSL property values.ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/topicAliasMaximum

Maximum topic aliases. This value, if present, represents the highest value the client will accept as a topic alias sent by the server.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/userName

Username to use to connect.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/userProperties

User properties. A user property is a pair of UTF-8 strings. The same name may appear several times.

Tableau à deux dimensions de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/useSubscriptionIdentifiers

Specifies if subscription identifiers need to be automatically allocated when subscribing to a topic.

BOOL
brokerConnection/will
subconf/config/brokerConfig/brokerConnection/will

"Last Will and Testament" (LWT) message for connection.

N / A
subconf/config/brokerConfig/brokerConnection/will/topicLWT topic.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/payloadLWT message payload.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/qosQuality of service level for publishing LWT messages.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/will/retainedSpecifies if the LWT message needs to be retained.BOOL

MQTT v5

subscribeTopic subscription information.

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/clientId

Client ID.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistanceMessage persistence mechanism.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistantFileDirectory

Message storage directory. Taken into account when "persistence" is "file".

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/manualAcks

Specifies if message acknowledgment is automatic or manual.

BOOL
subconf/config/brokerConfig/subscribeTopic/timeToWait

Maximum time to wait for an action with the broker to finish.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/topics

List of information about topics to subscribe to.

N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/topics)Size of the list of information about topics to subscribe to.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index starting at 1>]/topicFilterName of the <index> index topic in the list of information about topics to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topics[<index starting at 1>]/qosQuality of service level for receiving messages from the <index> index topic in the list of information about topics to subscribe to.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index starting at 1>]/retainAsPublishSpecifies if the broker retains the "retain" flag when sending a retained message to the subscriber.BOOL
subconf/config/brokerConfig/subscribeTopic/topics[<index starting at 1>]/noLocalUsed to not receive the messages published by the subscriber.BOOL
subconf/config/brokerConfig/subscribeTopic/topics[<index starting at 1>]/retainHandling

Specifies if the server sends the retained message to the client when establishing a subscription (values 0 to 2).

NUM_BIN_4


. Nats Jetstream

Nats Jetstream

brokerConnection connection information

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
brokerConnection/jetStreamCtx
subconf/config/brokerConfig/brokerConnection/jetStreamCtxJetstream connection context.N / A
subconf/config/brokerConfig/brokerConnection/jetStreamCtx/prefix

Prefix for Jetstream topics.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/jetStreamCtx/requestTimeout

Request timeout for Jetstream API calls.

ALPHA(n)
brokerConnection/natsCon
subconf/config/brokerConfig/brokerConnection/natsConNats connection parameters.N / A
subconf/config/brokerConfig/brokerConnection/natsCon/bufferSize

Initial size of buffers in the connection, mainly for testing.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/connectionNameConnection name.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/connectionTimeout

Connection attempt timeout.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/dataPortType

Java class to use for this connection data port.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/discardMessagesWhenOutgoingQueueFull

Enables discard messages when the outgoing queue is full.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/inboxPrefix

Connection's inbox prefix.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/maxControlLine

Maximum length of a control line sent by this connection.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxMessagesInOutgoingQueue

Maximum number of messages in the outgoing queue.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxPingsOut

Maximum number of pings the client can have in flight.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxReconnects

Maximum number of reconnect attempts.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/noEcho

Turns off echo.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noHeaders

Disables header handling.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noNoResponders

Disables assistance with no response.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noRandomize

Disables server pool randomization.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/oldRequestStyle

Enables the old request style which uses a new inbox and new subscriber for each request.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/opentls

SSL context which accepts any server certificate and has no client certificate.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/pedantic

Enables pedantic mode for the server in relation to this connection.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/pingInterval

Interval between server ping attempts.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectBufferSize

Maximum number of bytes to buffer in the client when trying to reconnect.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectJitter

Wait time between reconnect attempts to the same server.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectJitterTls

Wait time of a tls/secure connection between reconnect attempts to the same server.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectWait

Wait time between reconnect attempts to the same server.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/requestCleanupInterval

Interval between cleaning passes on outstanding request futures that are cancelled or timeout in the application code.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/secure

Options for using the default SSL context if there is one.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/serversList of server URIs to connect to.ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/natsCon/traceConnection

Enables connection trace messages.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/turnOnAdvancedStats

Enables advanced statistics, mainly for tests/benchmarks.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/verbose

Enables verbose mode with the server.

BOOL
brokerConnection/natsCon/userInfo
subconf/config/brokerConfig/brokerConnection/natsCon/userInfoUser information.N / A
subconf/config/brokerConfig/brokerConnection/natsCon/userInfo/userNameUsername for basic authentication.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/userInfo/passwordPassword for basic authentication.ALPHA(n)

Nats Jetstream

subscribeTopic subscription information.

Details in Apache Paho MQTTv3 documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/subjectName of topic to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queueGroupNameName of queue group to join.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/subscribeTypeMessage subscription type.ALPHA(n)
subscribeTopic/pushSubOpts
subconf/config/brokerConfig/subscribeTopic/pushSubOpts"PUSH" subscription information.N / A
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/deliverGroupSets the delivery group.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/deliverSubjectSets the delivery subject.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/durableSets a durable subscriber name.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/streamName of stream containing the topic to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/bindBinds the durable subscriber to the stream.BOOL
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pendingMessageLimit

Limits on the maximum number of messages the consumer will retain before starting to delete new messages until the application empties the queue.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pendingByteLimitLimits on the maximum size of messages the consumer will retain before starting to delete new messages until the application empties the queue.NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pushMaxWaitMaximum wait time to receive a message.ALPHA(n)
subscribeTopic/pushSubOpts/consumerConfig
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfigConsumer configuration information.N / A
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/ackPolicyMessage acknowledgment mode.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/ackWait

Acknowledgment wait time.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/deliverPolicy

Strategy for delivering messages to the consumer.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/descriptionSets a description for this configuration.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/filterSubject

Filter subject.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/flowControl

Enables flow control.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/idleHeartbeat

Wait time for consumer's idle heartbeats.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxAckPending

Maximum number of pending acknowledgments.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxDeliver

Maximum number of message deliveries.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxPullWaiting

Maximum pull waiting: number of pulls that can be outstanding on a consumer in "PULL" mode. Pulls received after this number has been reached are ignored.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/rateLimit

Rate limit (number of messages per second).

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/replayPolicy

Message replay strategy.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/sampleFrequency

Sampling frequency.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/startSequence

Start sequence for message acquisition in the stream.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/startTimeStart time for message acquisition in the stream.ALPHA(n)
subscribeTopic/pullSubOpts
subconf/config/brokerConfig/subscribeTopic/pullSubOpts"PULL" type subscription information.N / A
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/durableDurable subscriber name.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/streamName of stream containing the topic to subscribe to.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/bindBinds the durable subscriber to the stream.BOOL
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullTypeAcquisition mode for messages in "PULL" mode.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullBatchSizeMaximum number of messages retrieved in a batch.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullMaxWaitMaximum wait time for the batch to receive messages.ALPHA(n)
subscribeTopic/pullSubOpts/consumerConfig
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfigConsumer configuration information.N / A
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/ackPolicyMessage acknowledgment mode.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/ackWait

Acknowledgment wait time.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/deliverPolicy

Strategy for delivering messages to the consumer.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/descriptionSets a description for this configuration.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/filterSubject

Filter subject.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/flowControl

Enables flow control.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/idleHeartbeat

Wait time for consumer's idle heartbeats.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxAckPending

Maximum number of pending acknowledgments.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxDeliver

Maximum number of message deliveries.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxPullWaiting

Maximum pull waiting, the number of pulls that can be outstanding on a consumer in 'PULL' mode. Pulls received after this number is reached are ignored.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/rateLimit

Rate limit (number of messages per second).

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/replayPolicy

Message replay strategy.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/sampleFrequency

Sampling frequency.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/startSequence

Start sequence for message acquisition in the stream.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/startTimeStart time for message acquisition in the stream.ALPHA(n)


. RabbitMQ AMQP

RabbitMQ AMQP

brokerConnection connection information.

Details in Lettuce Redis Client documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/brokerConnection/username

Username to use to connect to the server.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/passwordPassword to use to connect to the server.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/encryptedPasswordSpecifies if the password is encrypted.BOOL
subconf/config/brokerConfig/brokerConnection/virtualHostName of virtual host to connect to.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/hostName of host to connect to.ALPHA(n)
subconf/config/brokerConfig/brokerconnection/portNumber of TCP port used to connect to the server.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/handshakeTimeout

Connection handshake timeout.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/shutdownTimeout

Maximum wait time for client shutdown.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/clientPropertiesClient properties hash table.N / A
adelUtils:mapKeys(subconf/config/brokerConfig/brokerConnection/clientProperties)

List of property names in the client properties hash table.

ALPHA(n) array
adelUtils:mapValues(subconf/config/brokerConfig/brokerConnection/clientProperties)List of values associated with properties in the client properties hash table.ALPHA(n) array
subconf/config/brokerConfig/brokerConnection/topologyRecoveryEnabled

Enables topology recovery (queues, exchange, binding, etc.) when the connection to the server is lost.

BOOL
subconf/config/brokerConfig/brokerConnection/useSslEnables the TLS protocol with the default parameters for connecting to the server.BOOL
brokerConnection/ssl
subconf/config/brokerConfig/brokerConnection/sslSSL/TLS connection parameters.N / A
subconf/config/brokerConfig/brokerConnection/ssl/hostnameVerificationEnables host name verification.BOOL
subconf/config/brokerConfig/brokerConnection/ssl/peerVerificationEnables peer verification.BOOL
brokerConnection/connection
subconf/config/brokerConfig/brokerConnection/connectionTCP connection parameters.N / A
subconf/config/brokerConfig/brokerConnection/connection/channelMax

Maximum channel number requested.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/frameMax

Maximum frame size requested.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/heartbeatInterval in seconds between heartbeat verifications between client and server.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/timeout

TCP connection timeout.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/recoveryEnabled

Enables automatic connection recovery.

BOOL
subconf/config/brokerConfig/brokerConnection/connection/recoveryInterval

Connection recovery interval.

NUM_BIN_8
brokerConnection/channel
subconf/config/brokerConfig/brokerConnection/channelParameters of channels used to connect to the server.N / A
subconf/config/brokerConfig/brokerConnection/channel/rpcTimeout

Continuation time for RPC calls in channels.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/channel/shouldCheckRpcResponseType

Enables RPC call response type check.

BOOL
subconf/config/brokerConfig/brokerConnection/useNio

Uses non-blocking I/O (NIO) to communicate with the server.

BOOL
brokerConnection/nio
subconf/config/brokerConfig/brokerConnection/nioNIO parameters.N / A
subconf/config/brokerConfig/brokerConnection/nio/readByteBufferSize

Size in bytes of the read ByteBuffer used in the NIO loop.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeByteBufferSize

Size in bytes of the write ByteBuffer used in the NIO loop.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/nbIoThreads

Maximum number of threads/tasks used for NIO.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeEnqueuingTimeoutInMs

Wait time for outgoing frame enqueuing.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeQueueCapacity

Queue capacity used for outgoing frames.

NUM_BIN_4

RabbitMQ AMQP

subscribeTopic subscription information.

Details in Lettuce Redis Client documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/consumerTag

Subscriber ID.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/consumerPrefetchCount

Maximum number of messages the server will deliver.

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/autoAckEnables automatic message acknowledgment.BOOL
subconf/config/brokerConfig/subscribeTopic/exclusiveConsumerSubscriber as the exclusive consumer of the associated queue.BOOL
subscribeTopic/consumerArgs
subconf/config/brokerConfig/subscribeTopic/consumerArgsConsumer properties.N / A
subconf/config/brokerConfig/subscribeTopic/consumerArgs/xPriorityConsumer priority in the group.NUM_BIN_4
subscribeTopic/queue
subconf/config/brokerConfig/subscribeTopic/queueProperties of the queue associated with the consumer.N / A
subconf/config/brokerConfig/subscribeTopic/queue/nameQueue name.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/declarePassiveUses an existing queue in the topology or creates a new queue.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/durableQueue persistence.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/autoDeleteQueue lifespan.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/exclusiveQueue exclusivity.BOOL
subscribeTopic/queue/queueArgs
subconf/config/brokerConfig/subscribeTopic/queue/queueArgsAdditional information about the queue behavior.N / A
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMessageTtlLifespan of messages in the queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xExpiresMaximum queue idle time (no associated subscriber) before deletion.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxLengthMaximum number of messages contained in the queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxLengthBytesMaximum number of bytes contained in the queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xOverflowBehavior of a full queue when it receives a new message.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xDeadLetterExchange

Name of an exchange to republish "dead letter" messages to from a queue (messages received by the queue in specific conditions).

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xDeadLetterRoutingKeyRouting key to use for "dead letter" messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxPriorityQueue priority level.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xQueueModeBackup mode for messages in the queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xQueueMasterLocatorMaster queue location in a distributed server environment.ALPHA(n)
subscribeTopic/queue/bind
subconf/config/brokerConfig/subscribeTopic/queue/bindList of queue-to-exchange binding information.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/routingKeyRouting key used to bind the exchange to the queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgsHash table of exchange and queue bind properties.

N / A

adelUtils:mapKeys(subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgs)List of property names in the hash table of exchange and queue bind properties.ALPHA(n) array
adelUtils:mapValues(subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgs)List of values associated with properties in the exchange and queue bind properties hash table.ALPHA(n) array
subscribeTopic/queue/bind[<index>]/exchange
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchangeInformation on exchange bound to the queue.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/nameName of exchange bound to the queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/typeType of exchange bound to the queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/durableExchange persistence.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/autoDeleteExchange lifespan.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/declarePassiveUses an existing exchange in the topology or creates a new exchange.BOOL
subscribeTopic/queue/bind[<index>]/exchange/exchangeArgs
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/exchangeArgsAdditional information about the exchange behavior.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/exchangeArgs/alternateExchangeName of an alternative exchange used when the exchange is unable to route a message.ALPHA(n)


. Redis Pub/Sub

Redis Pub/Sub

brokerConnection connection information.

Details in Lettuce Redis Client documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/brokerConnection/redisType

Specifies the type of Redis server to use.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIURI of the Redis server used for the connection.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientNameClient name.ALPHA(n)
brokerConnection/redisURIObj
subconf/config/brokerConfig/brokerConnection/redisURIObjInformation about the connection used to connect to a Redis server. Taken into account if "redisURI" is not entered.N / A
subconf/config/brokerConfig/brokerConnection/redisURIObj/usernameUsername used to connect.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/passwordPassword used to connect.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/databaseDatabase to connect to on the Redis server.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslUses an SSL connection.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/startTlsEnables StartTLS with SSL connection.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/timeoutMaximum wait time to establish the connection.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslVerifyPeer

Enables peer verification.

BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslVerifyPeerModePeer verification mode.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/encryptedPasswordSpecifies if the password is encrypted.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/hostRedis server host name.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/portNumber of TCP port used to connect to the server.NUM_BIN_4
brokerConnection/clientOptions
subconf/config/brokerConfig/brokerConnection/clientOptions

Options for checking the behavior of the Redis client.

N / A
subconf/config/brokerConfig/brokerConnection/clientOptions/autoReconnect

Enables automatic reconnection if the connection is lost.

BOOL
subconf/config/brokerConfig/brokerConnection/clientOptions/reconnectCloseTimeoutSuccessful reconnection attempt wait time before definitively closing the subscriber.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/clientOptions/protocolVersionProtocol version to use to connect.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientOptions/commandsTimeoutMaximum wait time for a server command response.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientOptions/pingBeforeActivateConnection

Defines the sending of a PING before activating the connection.

BOOL

Redis Pub/Sub

subscribeTopic subscription information.

Details in Lettuce Redis Client documentation

Key valueProperty descriptionProperty type
subconf/config/brokerConfig/subscribeTopic/channels

List of channels to subscribe to.

ALPHA(n) array
subconf/config/brokerConfig/subscribeTopic/patternsList of channel patterns to subscribe to.ALPHA(n) array


When this instruction is executed, the *RETURN_CODE reserved word can take the following values:

0 (*NORMAL)

Operation completed successfully.

-1

Internal error.

-2

XPath syntax error when evaluating the PropertyName parameter.

-3

The reserved word parameter is not known.

-4

The key corresponds to information that does not exist or has no value.

-11 The value associated with the key cannot be converted to Adelia type.
-32 The result variable must be an ALPHA or REF_CLASS type variable.
-33 The ALPHA result variable is too short.
-53 The result variable must be a numeric variable.
-54 The NUM_E/NUM_P result variable is too small.
-55 The integer part of the NUM_E/NUM_P result variable is too small.
-56 The decimal part of the NUM_E/NUM_P result variable is too small.
-57 The result variable has a type which is incompatible with a numeric value.
-58 The NUM_BIN_2 result variable is too small.
-59 The NUM_BIN_4 result variable is too small.
-60 The NUM_BIN_8 result variable is too small.
-61 The value associated with the key cannot be converted to TIMESTAMP type.
-74 The result variable must be a Boolean variable.
-95 The result variable must be a DATE, TIME or TIMESTAMP variable.
-116 The result variable must be an IMAGE variable.
-117

The value associated with the key cannot be converted to a byte array.

-137 The resulting variable must be a REF_CLASS variable.
-138 The value associated with the key cannot be converted to an Adelia class.
-300 The result variable must be an array variable.
-301 The result variable must be a one-dimensional array variable.
-302 The array result variable is too small.
-303 The combo box items have a type that cannot be converted to a numerical value.
-304 The combo box items have a type that cannot be converted to an alphanumeric value.
-305 The combo box items have a type that cannot be converted to a Boolean value.
-306 The combo box items have a type that cannot be converted to an image value.
-307 The combo box items have a type that cannot be converted to an Adelia class value.
-308 The result variable type is not supported.
-309 The key's combo box items have a type that cannot be converted to a date/time/timestamp value.
-332 The result array variable must be ALPHA or REF_CLASS type.
-333 The alphanumeric length of the ALPHA result array variable is too short.
-353 The result array variable must be numeric.
-354 The NUM_E/NUM_P result array variable defines numerics that are too small.
-355 The NUM_E/NUM_P result array variable defines numerics with an integer part that is too small.
-356 The NUM_E/NUM_P result array variable defines numerics with a decimal part that is too small.
-357 The combo box items have a type that cannot be converted to a numerical value.
-358 The NUM_BIN_2 result array variable defines integers that are too small.
-359 The NUM_BIN_4 result array variable defines integers that are too small.
-360 The NUM_BIN_8 result array variable defines integers that are too small.
-361 The key's combo box items have a value that cannot be converted to TIMESTAMP type.
-374 The result array variable must be Boolean type.
-395 The result array variable must be date, time or timestamp type.
-416 The result array variable must be image type.
-417 The key's combo box items have a type that cannot be converted to a byte array.
-437 The result array variable must be REF_CLASS type.
-438 The key's combo box items have a type that cannot be converted to an Adelia class.
-600 The value associated with the key cannot be converted to Adelia type.
-621 The alphanumeric value associated with the key cannot be deserialized to an Adelia class.
-642 The numeric value associated with the key cannot be converted to Adelia numeric type.
-705 Error when retrieving the byte array from a ByteBuffer instance.
-706

The ByteBuffer instance has no accessible byte array.

-707 The byte array value associated with the key cannot be deserialized to an Adelia class.
-900 The value associated with the key cannot be converted to Adelia type.
-1521 The alphanumeric value associated with the key cannot be deserialized to an Adelia class.
-1542 The numeric value associated with the key cannot be converted to Adelia numeric type.
-1605 Error when retrieving the byte array from a ByteBuffer instance.
-1606 The ByteBuffer instance has no accessible byte array.
-1607 The byte array value associated with the key cannot be deserialized to an Adelia class.

For example

* Broker name retrieval

ALPHA(128) BROKER_NAME

BRK_GET_CONF *BRK_NAME BROKER_NAME


* Subscriber name retrieval

ALPHA(128) SUBSCRIBER_ID

BRK_GET_CONF 'subconf/id' SUBSCRIBER_ID


* List of subscribed topics retrieval

ALPHA(64) TOPICS_ARRAY (3)

BRK_GET_CONF 'subconf/config/brokerConfig/subscribeTopic/topics' TOPICS_ARRAY


↑ Top of page


  • Aucune étiquette