Skip to content

Commit 06873f8

Browse files
authored
Feature/566 Notifications for Position Updates (#57)
* Produce message to notificiation topic. Unit tests fail * Fix code inaccuracy. Unit tests fail * Remove unused code. * Added stub for settlementTransferReserve * Remove unused requires * Reworked unit tests. * Corrected unit tests and provide full tests coverage
1 parent 85c0c0b commit 06873f8

13 files changed

Lines changed: 2982 additions & 147 deletions

File tree

‎config/default.json‎

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,5 +6,41 @@
66
"HUB_PARTICIPANT": {
77
"ID": 1,
88
"NAME": "Hub"
9+
},
10+
"KAFKA": {
11+
"TOPIC_TEMPLATES": {
12+
"GENERAL_TOPIC_TEMPLATE": {
13+
"TEMPLATE": "topic-{{functionality}}-{{action}}",
14+
"REGEX": "topic-(.*)-(.*)"
15+
}
16+
},
17+
"PRODUCER": {
18+
"NOTIFICATION": {
19+
"EVENT": {
20+
"config": {
21+
"options": {
22+
"messageCharset": "utf8"
23+
},
24+
"rdkafkaConf": {
25+
"debug": "all",
26+
"metadata.broker.list": "localhost:9092",
27+
"client.id": "cs-prod-notification-event",
28+
"event_cb": true,
29+
"compression.codec": "none",
30+
"retry.backoff.ms": 100,
31+
"message.send.max.retries": 2,
32+
"socket.keepalive.enable": true,
33+
"queue.buffering.max.messages": 10000000,
34+
"batch.num.messages": 100,
35+
"dr_cb": true,
36+
"socket.blocking.max.ms": 1,
37+
"queue.buffering.max.ms": 1,
38+
"broker.version.fallback": "0.10.1.0",
39+
"api.version.request": true
40+
}
41+
}
42+
}
43+
}
44+
}
945
}
1046
}

0 commit comments

Comments
 (0)