Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Reset heartbeats on business message sent #63

Merged
merged 9 commits into from
Sep 19, 2023
Merged
26 changes: 20 additions & 6 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# th2-conn-dirty-fix (1.4.1)
# th2-conn-dirty-fix (1.4.2)

This microservice allows sending and receiving messages via FIX protocol

Expand Down Expand Up @@ -49,6 +49,7 @@ This microservice allows sending and receiving messages via FIX protocol
+ *useNextExpectedSeqNum* - session management based on next expected sequence number. (`false` by default)
+ *saveAdminMessages* - defines if admin messages will be saved to internal outgoing buffer. (`false` by default)
+ *resetStateOnServerReset* - whether to reset the server sequence after receiving logout with text `Next Expected MSN too high, MSN to be sent is x but received y`.
+ *logoutOnIncorrectServerSequence* - whether to logout session when server send message with sequence number less than expected. If `false` then internal conn sequence will be reset to sequence number from server message.
+ *connectionTimeoutOnSend* - timeout in milliseconds for sending message from queue thread
(please read about [acknowledgment timeout](https://www.rabbitmq.com/consumers.html#acknowledgement-timeout) to understand the problem).
_Default, 30000 mls._
Expand Down Expand Up @@ -332,21 +333,34 @@ spec:

# Changelog

# 1.4.1
## 1.4.2
* Ungraceful session disconnect support.
* Removed NPE when session is reset by schedule.

## 1.4.1
* Timeout on send from queue thread
* Parameter `connectionTimeoutOnSend` was added

# 1.4.0
## 1.4.0
* Updated bom: `4.5.0-dev`
* Updated common: `5.4.0-dev`
* Updated common-utils: `2.2.0-dev`
* Updated grpc-lw-data-provider: `2.1.0-dev`
* Updated kotlin: `1.8.22`

# 1.3.0
* Added support for th2 transport protocol

# 1.2.1
## 1.3.2
* Improve logging: log session group and session alias for each log message.

## 1.3.1
* fix multiple consequent SOH characters

## 1.3.0
* Added handling for incoming test request messages
* Fixed resetSeqNum flag handling on incoming logon messages.
* Added option to automatically reset server sequence when internal conn sequence doesn't match with sequence that server sent.

## 1.2.1
* fix multiple consequent SOH characters

## 1.2.0
Expand Down
4 changes: 2 additions & 2 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -51,14 +51,14 @@ dependencies {
exclude group: 'com.exactpro.th2', module: 'task-utils'
}
implementation "com.exactpro.th2:common-utils:2.2.0-dev"

implementation 'com.exactpro.th2:netty-bytebuf-utils:0.0.1'
implementation 'com.exactpro.th2:conn-dirty-tcp-core:3.2.0-dev'
implementation 'com.exactpro.th2:conn-dirty-tcp-core:3.2.1-mangler_fix_3.2.1+'
implementation 'com.exactpro.th2:grpc-lw-data-provider:2.2.0-separate-executor-reverse-orders-917aa0b-SNAPSHOT'

implementation 'org.slf4j:slf4j-api'
implementation 'io.github.microutils:kotlin-logging:3.0.0' // The last version bases on kotlin 1.6.0
implementation 'org.apache.commons:commons-lang3'
implementation 'org.apache.commons:commons-lang3:3.13.0'

implementation 'io.netty:netty-all'
implementation 'com.google.auto.service:auto-service:1.0.1'
Expand Down
3 changes: 1 addition & 2 deletions gradle.properties
Original file line number Diff line number Diff line change
@@ -1,2 +1 @@
release_version=1.4.1

release_version=1.4.2
Loading