Skip to content

Commit

Permalink
[TH2-5148] Fixed conn write sailfish service logs into last sailfish …
Browse files Browse the repository at this point in the history
…workspace layer problem (#192)

* Disabled appenders
  • Loading branch information
Nikita-Smirnov-Exactpro authored Aug 7, 2024
1 parent 1f4731f commit 5a42804
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 11 deletions.
5 changes: 4 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# Connect (4.1.0)
# Connect (4.1.1)

The "Connect" component is responsible for the communication with a target system.
This component implements the logic of the interaction protocol, receiving and sending messages from and to the system, respectively.
Expand Down Expand Up @@ -127,6 +127,9 @@ spec:

## Release notes

### 4.1.1
+ Fixed conn write sailfish service logs into last sailfish workspace layer problem

### 4.1.0

+ Migrate to th2 gradle plugin `0.1.1`
Expand Down
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1 +1 @@
release_version = 4.1.0
release_version = 4.1.1
18 changes: 9 additions & 9 deletions src/main/java/com/exactpro/th2/conn/MicroserviceMain.java
Original file line number Diff line number Diff line change
Expand Up @@ -133,8 +133,10 @@ public static void main(String[] args) {
processor.onComplete();
});

IServiceFactory serviceFactory = new ServiceFactory(workspaceFolder,
Files.createTempDirectory("sailfish-workspace").toFile());
IServiceFactory serviceFactory = ServiceFactory
.builder(workspaceFolder, Files.createTempDirectory("sailfish-workspace").toFile())
.useServiceAppenders(false)
.build();
disposer.register(() -> {
LOGGER.info("Close service factory");
serviceFactory.close();
Expand Down Expand Up @@ -280,13 +282,11 @@ private static Object getParamValue(ISettingsProxy settings, String parameterNam
LOGGER.info("AvailableProcessors '{}'", Runtime.getRuntime().availableProcessors());

ConnectableFlowable<ConnectivityMessage> messageConnectable = flowable
.doOnNext(message -> {
LOGGER.trace(
"Message before observeOn with sequence {} and direction {}",
message.getSequence(),
message.getDirection()
);
})
.doOnNext(message -> LOGGER.trace(
"Message before observeOn with sequence {} and direction {}",
message.getSequence(),
message.getDirection()
))
.observeOn(PIPELINE_SCHEDULER)
.doOnNext(connectivityMessage -> {
LOGGER.debug("Start handling connectivity message {}", connectivityMessage);
Expand Down

0 comments on commit 5a42804

Please sign in to comment.