You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+38-8Lines changed: 38 additions & 8 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -1,19 +1,36 @@
1
-
# Overview (5.0.2)
1
+
# Overview (5.2.1)
2
2
3
3
Message store (mstore) is an important th2 component responsible for storing raw messages into Cradle. Please refer to [Cradle repository] (https://github.com/th2-net/cradleapi/blob/master/README.md) for more details. This component has a pin for listening messages via MQ.
4
4
5
-
Users must mark a pin that produces raw messages in conn, read and hand boxes via the "store" attribute, in order to automatically connect that pin to mstore and to collect all messages into Cradle.
5
+
## Protobuf raw message
6
6
7
-
Raw message is a base entity of th2. All incoming / outgoing data is stored in this format
8
-
Every raw message contains important parts:
7
+
Users must mark a pin that produces protobuf raw messages in conn, read and hand boxes via the "store" attribute, in order to automatically connect that pin to mstore and to collect all messages into Cradle.
8
+
9
+
Protobuf raw message is a base entity of th2. All incoming / outgoing data is stored in this format
10
+
Every protobuf raw message contains important parts:
9
11
* book - name of the book
10
12
* session alias - unique identifier of business session.
11
13
* session group - group id for this session
12
14
* direction - direction of message stream.
13
15
* sequence number - incremental identifier.
14
16
* data - byte representation of raw message
15
17
16
-
book, session alias, direction and sequence number are a **compound unique identifier** of raw messages within th2
18
+
book, session alias, direction and sequence number are a **compound unique identifier** of protobuf raw messages within th2
19
+
20
+
## Transport raw message
21
+
22
+
Users must connect a pin that produces transport raw messages in conn, read and hand boxes via the general link approach, in order to manually connect that pin to mstore and to collect all messages into Cradle.
23
+
24
+
Transport raw message is a new entity of th2. You can read more details about th2 transport protocol by the [link] (https://exactpro.atlassian.net/wiki/spaces/TH2/pages/1048838145/TH2+Transport+Protocol). All incoming / outgoing data is stored in this format
25
+
Every protobuf raw message contains important parts:
26
+
* book - name of the book
27
+
* session alias - unique identifier of business session.
28
+
* session group - group id for this session
29
+
* direction - direction of message stream.
30
+
* sequence number - incremental identifier.
31
+
* data - byte representation of raw message
32
+
33
+
book, session alias, direction and sequence number are a **compound unique identifier** of protobuf raw messages within th2
17
34
18
35
# Configuration
19
36
@@ -72,6 +89,13 @@ spec:
72
89
prefetchRatioToDrain: 0.8
73
90
maxBatchSize: 200000
74
91
termination-timeout: 5000
92
+
pins:
93
+
mq:
94
+
subscribers:
95
+
- name: transport
96
+
attributes:
97
+
- transport-group
98
+
- subscribe
75
99
extended-settings:
76
100
service:
77
101
enabled: false
@@ -91,16 +115,22 @@ spec:
91
115
This is a list of supported features provided by libraries.
92
116
Please see more details about this feature via [link](https://github.com/th2-net/th2-common-j#configuration-formats).
93
117
94
-
## 5.0.2
118
+
## 5.2.1
95
119
96
-
+ Fixed the problem: batches for the same session group and different books are separate storing
120
+
+ Fixed the problem: batches for the same session group and different books are separate storing
121
+
122
+
## 5.2.0
123
+
* Updated bom: `4.5.0-dev`
124
+
* Updated common: `5.4.0-dev`
125
+
126
+
## 5.1.0
127
+
+ Provided ability to process th2 transport messages
0 commit comments