These 66 commits are when the Protocol Buffers files have changed:
| Commit: | 1023abc | |
|---|---|---|
| Author: | dlandiak | |
added TbmqSystemInfoServiceTest
The documentation is generated from this commit.
| Commit: | d078fe9 | |
|---|---|---|
| Author: | dlandiak | |
init implementation of service system info usage
| Commit: | abd5a93 | |
|---|---|---|
| Author: | dlandiak | |
feature integration executor with http integration and events
| Commit: | 9471320 | |
|---|---|---|
| Author: | dlandiak | |
subscriptions loading and persistence to Kafka refactoring with introducing the source of subscription
| Commit: | dd57635 | |
|---|---|---|
| Author: | dlandiak | |
make queue.proto with java_multiple_files=true
| Commit: | e0fc457 | |
|---|---|---|
| Author: | dlandiak | |
license headers update
| Commit: | 919ffe6 | |
|---|---|---|
| Author: | dlandiak | |
subscription identifier main logic implemented
| Commit: | ce24f36 | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'develop/1.2.2' into feature/subscription-identifier
| Commit: | 7ccea16 | |
|---|---|---|
| Author: | dlandiak | |
disconnect client command improved to pass correct reason code - on session conflict or admin session
| Commit: | e578321 | |
|---|---|---|
| Author: | dlandiak | |
mqtt 5 feature: subscription id init, fixed trying delete old CG that has consumers (when state not empty)
| Commit: | 77600f5 | |
|---|---|---|
| Author: | dlandiak | |
Update license header to 2024 year
| Commit: | 904fe9f | |
|---|---|---|
| Author: | dlandiak | |
Revert "Update license header to 2024 year" This reverts commit 6ce8213da98c5b17d3017b89b70db07b72b523b4.
| Commit: | 6ce8213 | |
|---|---|---|
| Author: | dlandiak | |
Update license header to 2024 year
| Commit: | 99600d1 | |
|---|---|---|
| Author: | dlandiak | |
request-response mqtt 5 feature implementation
| Commit: | d11108f | |
|---|---|---|
| Author: | dlandiak | |
MQTT 5: payload format and content types feature init implementation
| Commit: | e77b587 | |
|---|---|---|
| Author: | dlandiak | |
removed todos
| Commit: | 5cb1d18 | |
|---|---|---|
| Author: | Andrii Landiak | |
Implement historical data stats saving: add new kafka topic
| Commit: | c0da822 | |
|---|---|---|
| Author: | dlandiak | |
removed sessionInfoProto from publish msg proto
| Commit: | bf179d0 | |
|---|---|---|
| Author: | dlandiak | |
changed client ip to byte array for client session
| Commit: | 5f22860 | |
|---|---|---|
| Author: | dlandiak | |
client session - expiry interval to int
| Commit: | 4985330 | |
|---|---|---|
| Author: | dlandiak | |
removed lastUpdateTime from client session info
| Commit: | 34287e1 | |
|---|---|---|
| Author: | dlandiak | |
added createdTime for retained message
| Commit: | b33e565 | |
|---|---|---|
| Author: | dlandiak | |
added client ip address to client session
| Commit: | 69002e7 | |
|---|---|---|
| Author: | dlandiak | |
license headers update to 2023
| Commit: | c5dfc0c | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'main' into feature/session-expiry
| Commit: | c69c5f9 | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'main' into feature/subscription-options
| Commit: | 41d7abc | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'main' into feature/server-keep-alive
| Commit: | 2519213 | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'main' into feature/will-delay
| Commit: | 3a517b2 | |
|---|---|---|
| Author: | Dima Landiak | |
session expiry implementation, not finished
| Commit: | 7bc5e04 | |
|---|---|---|
| Author: | dlandiak | |
session expiry in disconnect
| Commit: | f3499e0 | |
|---|---|---|
| Author: | Dima Landiak | |
session expiry init
| Commit: | 051f8a4 | |
|---|---|---|
| Author: | dlandiak | |
Merge branch 'main' into feature/user-properties
| Commit: | 242dce4 | |
|---|---|---|
| Author: | dlandiak | |
retainAsPublish subscribe option
| Commit: | 03f0af4 | |
|---|---|---|
| Author: | Dima Landiak | |
no local subscribe option
| Commit: | 13de79d | |
|---|---|---|
| Author: | Dima Landiak | |
send last will with delay from mqtt properties
| Commit: | 9a75522 | |
|---|---|---|
| Author: | Dima Landiak | |
user properties implementation
| Commit: | 1586fad | |
|---|---|---|
| Author: | Dima Landiak | |
shared subs improvements
| Commit: | 56903a2 | |
|---|---|---|
| Author: | Dima Landiak | |
renamed groupId to shareName for shared subscriptions, added validation
| Commit: | 795d0df | |
|---|---|---|
| Author: | dlandiak | |
shared subscriptions impl
| Commit: | 12cabd4 | |
|---|---|---|
| Author: | dlandiak | |
send retained msgs when client is subscribing
| Commit: | 351c917 | |
|---|---|---|
| Author: | Dima Landiak | |
retained msg kafka queue init
| Commit: | 59f3e01 | |
|---|---|---|
| Author: | Dima Landiak | |
Update license year to 2022
| Commit: | 5efa753 | |
|---|---|---|
| Author: | vzikratyi | |
| Committer: | vzikratyi | |
Added clearing of ApplicationTopic
| Commit: | 34f76a1 | |
|---|---|---|
| Author: | vzikratyi | |
added endpoint to get DetailedClientSessionInfo
| Commit: | 51772cf | |
|---|---|---|
| Author: | vzikratyi | |
Renamed PersistedDevicePublishMsg to DevicePublishMsg
| Commit: | 03011ce | |
|---|---|---|
| Author: | vzikratyi | |
Used 'topic' as kafka key
| Commit: | 7811a19 | |
|---|---|---|
| Author: | vzikratyi | |
Check if prev session was persistent in SessionClusterManager
| Commit: | 1d87a83 | |
|---|---|---|
| Author: | vzikratyi | |
Removed ClusterEvent logic
| Commit: | 85a2c38 | |
|---|---|---|
| Author: | vzikratyi | |
Added Cluster events
| Commit: | 046b37e | |
|---|---|---|
| Author: | vzikratyi | |
Updated TODOs
| Commit: | 05e4ba8 | |
|---|---|---|
| Author: | vzikratyi | |
Implemented distribution of PUBLISH messages between Nodes
| Commit: | 2261e71 | |
|---|---|---|
| Author: | vzikratyi | |
Removed DevicePublishMsgProto
| Commit: | 0d5971c | |
|---|---|---|
| Author: | vzikratyi | |
Made separate event_response/disconnect_command topic for each Node in cluster
| Commit: | 9844d59 | |
|---|---|---|
| Author: | vzikratyi | |
Added 'serviceId' to SessionInfo
| Commit: | 7a41f5c | |
|---|---|---|
| Author: | vzikratyi | |
Added zookeeper discovery service
| Commit: | d7cbe48 | |
|---|---|---|
| Author: | vzikratyi | |
Added 'lastUpdatedTime' to ClientSession
| Commit: | 9531840 | |
|---|---|---|
| Author: | vzikratyi | |
Added callback and retries to 'publish-msg' consumer, refactored
| Commit: | 8343b93 | |
|---|---|---|
| Author: | vzikratyi | |
Added DEVICE messages persistence (not finished)
| Commit: | d04265f | |
|---|---|---|
| Author: | vzikratyi | |
Added one service to process client CONNECTs and DISCONNECTs
| Commit: | d1e57ab | |
|---|---|---|
| Author: | vzikratyi | |
Remade APPLICATION msg persistence (all messages are pushed to client by consumer)
| Commit: | e468436 | |
|---|---|---|
| Author: | vzikratyi | |
Added persistence session for APPLICATION clients (not tested)
| Commit: | 65068c7 | |
|---|---|---|
| Author: | vzikratyi | |
Added LastWillService, refactored code
| Commit: | 548dc33 | |
|---|---|---|
| Author: | vzikratyi | |
Fixed package name, refactored
| Commit: | a8ea511 | |
|---|---|---|
| Author: | viktor | |
| Committer: | Andrew Shvayka | |
Basic infrastructure (not tested)
| Commit: | de8b76d | |
|---|---|---|
| Author: | viktor | |
| Committer: | Andrew Shvayka | |
Added services for MQTT server bootstrap
| Commit: | 39e3624 | |
|---|---|---|
| Author: | viktor | |
| Committer: | Andrew Shvayka | |
Message queue logic, MQTT msgs handling