Introducing LOKI annotation package related classes (for more detailed descriptions, click to view source code comments).
Annotation class package:
👉 loki-annotationopen in new window
- Description: message name annotation
| Attributes | Type | Required | Default | Description |
|---|
| topic | String | YES | none | Topic name |
| tag | String | NO | "" | Tag |
| producer | String | NO | "defaultProducer" | Producer |
| deliveryTimestamp | long | NO | 0 | Delay time |
| consumerGroup | String | NO | "defaultConsumerGroup" | Consumer group |
| consumptionThreadCount | int | NO | 20 | Number of threads consumed |
| maxCacheMessageCount | int | NO | 1024 | Maximum number of cached messages |
- Description: message key annotation
| Attributes | Type | Required | Default | Description |
|---|
| value | String | NO | "" | Field name (the value can be none) |
- Description:Send message annotation
| Attributes | Type | Required | Default | Description |
|---|
| topic | String | YES | none | Topic name |
| async | boolean | NO | false | Asynchronous send or not |
| message | String | YES | "" | Send a message, supporting SPEL expression |
| messageKey | String | NO | "" | Message key, which supports SPEL expression |
| tag | String | NO | "" | Tag |
| producer | String | NO | "defaultProducer" | Producer |
| deliveryTimestamp | long | NO | 0 | Delay time |
- Description: Message receiving annotation
| Attributes | Type | Required | Default | Description |
|---|
| topic | String | NO | none | Topic name Both topicPattern must have a value, topicPattern has higher precedence) |
| topicPattern | String | NO | none | Topic Pattern name (Both topicPattern must have a value, topicPattern has higher precedence) |
| tag | String | NO | "" | TAG |
| consumerGroup | String | NO | "defaultConsumerGroup" | Consumer group |
| consumptionThreadCount | int | NO | 20 | Number of threads consumed |
| maxCacheMessageCount | int | NO | 1024 | Maximum number of cached messages |