Proto commits in thingsboard/tbmq

These 97 commits are when the Protocol Buffers files have changed:

2026-07-01

feat(integration): add clientCertCn to client lifecycle events Carry the X.509 certificate Common Name as a common lifecycle-event field alongside username, populated from the session ctx in newSessionBuilder so it rides on every session-scoped event (CONNECTED/DISCONNECTED/SUBSCRIBED/ UNSUBSCRIBED/AUTHORIZATION_FAILED/CONNECTION_FAILED) when present. Emitted only for X.509-authenticated clients (omitted when empty, like username). New additive proto field; no UI change.

feat(integration): carry share name in CLIENT_UNSUBSCRIBED event CLIENT_UNSUBSCRIBED emitted only bare topic-filter strings, so a consumer could not tell a shared unsubscribe ($share/<group>/<filter>) from a regular one nor reconstruct the full filter. Emit the removed subscriptions structurally instead: - reuse the proto `subscriptions` field for CLIENT_UNSUBSCRIBED too (drop the bare `topicFilters` string list; renumber contiguously since the feature is unreleased) - the handler now matches unsubscribed filters against the client's current subscriptions by (shareName, bare filter) so $share/g1/foo resolves to that exact shared subscription, and passes the removed TopicSubscriptions to the publisher - the publisher writes only each removed subscription's identity (topic + shareName when shared) — an UNSUBSCRIBE names filters, not qos/options, so those are not put on the wire - the event body emits subscriptions[] with topicFilter and, when shared, shareName Tests: handler asserts the removed shared subscription carries its shareName; publisher asserts the proto carries topic + shareName; body asserts the JSON emits topicFilter + shareName (and omits shareName for a regular unsubscribe).

2026-06-30

feat(integration): add CLIENT_CONNECTION_FAILED lifecycle event Emit a dedicated lifecycle event when the broker refuses a connection (ClientSessionFailureReason: QUOTA_EXCEEDED / SERVER_UNAVAILABLE / UNSPECIFIED_ERROR) from ConnectServiceImpl.refuseConnection. Carries the failure reason (reuses the existing proto reason field). Rounds out the failure-event taxonomy alongside CLIENT_AUTHENTICATION_FAILED / CLIENT_AUTHORIZATION_FAILED; added to the UI lifecycle-events selector.

refactor(integration): drop anonymous from CLIENT_AUTHENTICATION_FAILED event The flag just mirrored whether username was empty; with empty username now omitted from the event body, a consumer infers anonymous from the absent username key. Remove it from the proto, publisher, and JSON body. Proto fields renumbered contiguously (unreleased, no wire-compat concern).

refactor(integration): drop clientInitiated from CLIENT_DISCONNECTED event The flag was derived solely from the disconnect reason (ON_DISCONNECT_MSG / ON_DISCONNECT_AND_WILL_MSG), so it is redundant with disconnectReason which is already in the event payload. Remove it from the proto, publisher, and JSON body. Proto fields renumbered contiguously since the feature is unreleased (no wire-compat concern).

refactor(integration): emit auth lifecycle events on failure only Rename CLIENT_AUTHENTICATED/CLIENT_AUTHORIZED to CLIENT_AUTHENTICATION_FAILED/CLIENT_AUTHORIZATION_FAILED and stop emitting auth success events: a successful authentication is already implied by CLIENT_CONNECTED, and emitting success before the connection is accepted produced orphan events. Authentication now emits only on failure, symmetric with authorization (deny-only). Drop the now-redundant result proto field (always FAILURE/DENY) and renumber ClientLifecycleEventMsgProto contiguously (feature unreleased).

2026-06-25

fix(integration): drop misleading authMethod from CLIENT_AUTHENTICATED event authMethod was populated from ctx.getAuthDetails() which holds the credential display name (not the auth provider type) and is empty on failures. Remove the field (proto field 17 left as a gap; unreleased) and drop all related builder calls, body serialization, and test assertions.

feat(integration): add auth/authz lifecycle event proto fields and enum values

2026-06-24

refactor(integration): remove TbIeMsgProto oneof from integration.proto

2026-06-11

feat: add CLIENT_UNSUBSCRIBED integration lifecycle event Publish a lifecycle event when a client unsubscribes, mirroring the CLIENT_SUBSCRIBED flow: - new ClientLifecycleEventType.CLIENT_UNSUBSCRIBED enum value - ClientLifecycleEventMsgProto gains a repeated topicFilters field (unsubscribe carries plain topic filters, no QoS) - IntegrationLifecycleEventPublisher.publishUnsubscribed, fired from MqttUnsubscribeHandler after the UNSUBACK is flushed - AbstractIntegration emits a "topicFilters" array for the unsubscribe body - UI: add the event type to the model enum, lifecycle multi-select and i18n

feat: add lifecycle event protos for integration fan-out and internode notification

2026-03-05

added clientCertCn to the integration json

The documentation is generated from this commit.

2026-01-16

http service auth provider init, auth dummy logic added

2026-01-13

license headers format for 2026

2026-01-07

introduce forceful session cleanup to fix and remove ghost sessions, improved cleanup service to mark persistent sessions disconnected when prev request failed

2026-01-06

introduce session connect with onConflict flag, connection response with reason, moved check session limit to the correct place

2026-01-01

session auth info and mqtt client version persistence moved to session cluster manager to fix wrong put and evict

add disconnect reason type into session event request

2025-06-26

Removed useListenerBasedProviderOnly

2025-06-19

Revert "migrated configuration from string to bytes" This reverts commit 939806f143eb307e000fe65a2540e7d36f7dddda.

migrated configuration from string to bytes

2025-06-13

Merge branch 'main' into mqtt-authenticators

2025-06-12

Improvements after self review

2025-06-02

Added SCRAM auth provider

2025-05-29

changed useJwtFirst to the priority list

2025-05-21

blocked client added main logic

2025-05-19

blocked client init implementation

2025-05-16

Added ability to handle MqttAuthSettings updates && rollback initial implementation on application side

2025-05-15

Moved processing of client session stats cleanup to internode kafka topic

renamed MqttClientAuthProvider to MqttAuthProvider

Added internode kafka consumer/producer

2025-04-04

added TbmqSystemInfoServiceTest

2025-04-03

init implementation of service system info usage

2025-02-19

feature integration executor with http integration and events

2025-01-31

subscriptions loading and persistence to Kafka refactoring with introducing the source of subscription

2025-01-28

make queue.proto with java_multiple_files=true

2024-12-31

license headers update

2024-08-21

subscription identifier main logic implemented

2024-03-18

Merge branch 'develop/1.2.2' into feature/subscription-identifier

disconnect client command improved to pass correct reason code - on session conflict or admin session

2024-02-22

mqtt 5 feature: subscription id init, fixed trying delete old CG that has consumers (when state not empty)

2024-02-05

Update license header to 2024 year

Revert "Update license header to 2024 year" This reverts commit 6ce8213da98c5b17d3017b89b70db07b72b523b4.

Update license header to 2024 year

2024-01-02

request-response mqtt 5 feature implementation

2023-11-27

MQTT 5: payload format and content types feature init implementation

2023-11-16

removed todos

2023-05-24

Implement historical data stats saving: add new kafka topic

2023-05-04

removed sessionInfoProto from publish msg proto

2023-03-24

changed client ip to byte array for client session

client session - expiry interval to int

2023-03-22

removed lastUpdateTime from client session info

2023-02-20

added createdTime for retained message

2023-02-17

added client ip address to client session

2023-02-07

license headers update to 2023

2022-11-14

Merge branch 'main' into feature/session-expiry

2022-10-31

Merge branch 'main' into feature/subscription-options

2022-10-28

Merge branch 'main' into feature/server-keep-alive

Merge branch 'main' into feature/will-delay

2022-10-27

session expiry implementation, not finished

2022-10-26

session expiry in disconnect

2022-10-25

session expiry init

2022-10-24

Merge branch 'main' into feature/user-properties

2022-10-18

retainAsPublish subscribe option

2022-10-17

no local subscribe option

2022-10-13

send last will with delay from mqtt properties

2022-10-06

user properties implementation

2022-09-27

shared subs improvements

2022-08-08

renamed groupId to shareName for shared subscriptions, added validation

2022-08-05

shared subscriptions impl

2022-07-27

send retained msgs when client is subscribing

2022-07-25

retained msg kafka queue init

2022-07-19

Update license year to 2022

2021-09-30

Added clearing of ApplicationTopic

2021-09-22

added endpoint to get DetailedClientSessionInfo

2021-07-26

Renamed PersistedDevicePublishMsg to DevicePublishMsg

2021-07-06

Used 'topic' as kafka key

2021-06-11

Check if prev session was persistent in SessionClusterManager

2021-06-10

Removed ClusterEvent logic

2021-06-08

Added Cluster events

2021-06-03

Updated TODOs

2021-05-27

Implemented distribution of PUBLISH messages between Nodes

Removed DevicePublishMsgProto

2021-05-17

Made separate event_response/disconnect_command topic for each Node in cluster

2021-05-14

Added 'serviceId' to SessionInfo

Added zookeeper discovery service

2021-04-14

Added 'lastUpdatedTime' to ClientSession

2021-03-12

Added callback and retries to 'publish-msg' consumer, refactored

2021-03-10

Added DEVICE messages persistence (not finished)

2021-03-02

Added one service to process client CONNECTs and DISCONNECTs

2021-02-10

Remade APPLICATION msg persistence (all messages are pushed to client by consumer)

2021-02-04

Added persistence session for APPLICATION clients (not tested)

2021-01-13

Added LastWillService, refactored code

2020-12-29

Fixed package name, refactored

2020-12-10

Message queue logic, MQTT msgs handling

Added services for MQTT server bootstrap

Basic infrastructure (not tested)