Skip to content

Commit

Permalink
Release 5.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
bitzl committed Oct 14, 2021
1 parent d8a968a commit f68da17
Show file tree
Hide file tree
Showing 5 changed files with 17 additions and 17 deletions.
21 changes: 10 additions & 11 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,15 @@ Java application).
<dependency>
<groupId>com.github.dbmdz.flusswerk</groupId>
<artifactId>framework</artifactId>
<version>4.1.0</version>
<version>5.0.0</version>
</dependency>
```

**Gradle:**

```groovy
dependencies {
compile group: 'com.github.dbmdz.flusswerk', name: 'flusswerk', version: '4.1.0'
compile group: 'com.github.dbmdz.flusswerk', name: 'flusswerk', version: '5.0.0'
}
```

Expand All @@ -33,15 +33,14 @@ To get started, clone or copy the [Flusswerk
Example](https://github.com/dbmdz/flusswerk-example) application.


## Migration to version 4

Starting with Flusswerk 4, there are two major changes:

- Any Flusswerk application uses now Spring Boot and needs beans for
[FlowSpec][FlowSpec] (defining the processing) and
[IncomingMessageType][IncomingMessageType].
- The package names changed from `de.digitalcollections.flusswerk.engine` to
`com.github.dbmdz.framework`.
## What's new in Flusswerk 5

- Flusswerk connections are now shown in RabbitMQ management UI
- structured logging now automatically contains fields `duration` and `duration_ms` that report the time your app spent on processing a certain message in seconds or milliseconds.
- The deprecated `tracing_id` has been removed
- The deprecated `Envelope.timestamp` has been removed in favor of `Envelope.created` which is now of type `Instant`.
- Constructor of FlusswerkApplication now takes `Optional<Engine>` as an argument (call as `super(Optional.of(engine));`).
- Options for centralized locking using Redis have been removed

[FlowSpec]:
framework/src/main/java/com/github/dbmdz/flusswerk/framework/flow/FlowSpec.java
Expand Down
2 changes: 1 addition & 1 deletion framework/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>com.github.dbmdz.flusswerk</groupId>
<artifactId>flusswerk</artifactId>
<version>5.0.0-SNAPSHOT</version>
<version>5.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,9 @@ public Collection<Message> process(Message message) {
} finally {
info.stop();
long stop = System.nanoTime();
double duration = (stop - start) / 1e6;
MDC.put("duration_ms", Double.toString(duration));
double duration = (stop - start) / 1e3;
MDC.put("duration", Double.toString(duration));
MDC.put("duration_ms", Double.toString(duration / 1e3));
flowMetrics.forEach(
metric -> metric.accept(info)); // record metrics only available from inside the framework
}
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
<parent>
<groupId>com.github.dbmdz.flusswerk</groupId>
<artifactId>flusswerk</artifactId>
<version>5.0.0-SNAPSHOT</version>
<version>5.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

<groupId>com.github.dbmdz.flusswerk</groupId>
<artifactId>flusswerk</artifactId>
<version>5.0.0-SNAPSHOT</version>
<version>5.0.0</version>
<packaging>pom</packaging>

<name>Flusswerk</name>
Expand Down Expand Up @@ -71,7 +71,7 @@
<!-- Dependency versions -->
<version.amqp-client>5.13.1</version.amqp-client>
<version.logstash-encoder>6.6</version.logstash-encoder>
<version.flusswerk>5.0.0-SNAPSHOT</version.flusswerk>
<version.flusswerk>5.0.0</version.flusswerk>
<version.junit>5.7.0</version.junit>
<version.mockito>4.0.0</version.mockito>
<!-- Plugin versions -->
Expand Down

0 comments on commit f68da17

Please sign in to comment.