530
530
< div id ="header ">
531
531
< h1 > RabbitMQ Stream Java Client</ h1 >
532
532
< div class ="details ">
533
- < span id ="revnumber "> version 0.10 .0-SNAPSHOT</ span >
534
- < br > < span id ="revremark "> (81b1409 )</ span >
533
+ < span id ="revnumber "> version 0.11 .0-SNAPSHOT</ span >
534
+ < br > < span id ="revremark "> (090d47c )</ span >
535
535
</ div >
536
536
< div id ="toc " class ="toc2 ">
537
537
< div id ="toctitle "> Table of Contents</ div >
@@ -1048,7 +1048,7 @@ <h4 id="maven"><a class="anchor" href="#maven"></a>Maven</h4>
1048
1048
< span class ="tag "> <dependency></ span >
1049
1049
< span class ="tag "> <groupId></ span > com.rabbitmq< span class ="tag "> </groupId></ span >
1050
1050
< span class ="tag "> <artifactId></ span > stream-client< span class ="tag "> </artifactId></ span >
1051
- < span class ="tag "> <version></ span > 0.10 .0-SNAPSHOT< span class ="tag "> </version></ span >
1051
+ < span class ="tag "> <version></ span > 0.11 .0-SNAPSHOT< span class ="tag "> </version></ span >
1052
1052
< span class ="tag "> </dependency></ span >
1053
1053
1054
1054
< span class ="tag "> </dependencies></ span > </ code > </ pre >
@@ -1064,7 +1064,7 @@ <h4 id="gradle"><a class="anchor" href="#gradle"></a>Gradle</h4>
1064
1064
< div class ="title "> build.gradle</ div >
1065
1065
< div class ="content ">
1066
1066
< pre class ="CodeRay highlight "> < code data-lang ="groovy "> dependencies {
1067
- compile < span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> com.rabbitmq:stream-client:0.10 .0-SNAPSHOT</ span > < span class ="delimiter "> "</ span > </ span >
1067
+ compile < span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> com.rabbitmq:stream-client:0.11 .0-SNAPSHOT</ span > < span class ="delimiter "> "</ span > </ span >
1068
1068
}</ code > </ pre >
1069
1069
</ div >
1070
1070
</ div >
@@ -4199,7 +4199,7 @@ <h5 id="filtering-on-the-publishing-side"><a class="anchor" href="#filtering-on-
4199
4199
< div class ="content ">
4200
4200
< pre class ="CodeRay highlight "> < code data-lang ="java "> Producer producer = environment.producerBuilder()
4201
4201
.stream(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> invoices</ span > < span class ="delimiter "> "</ span > </ span > )
4202
- .filter (msg ->
4202
+ .filterValue (msg ->
4203
4203
msg.getApplicationProperties().get(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> state</ span > < span class ="delimiter "> "</ span > </ span > ).toString()) < i class ="conum " data-value ="1 "> </ i > < b > (1)</ b >
4204
4204
.build();</ code > </ pre >
4205
4205
</ div >
@@ -4233,7 +4233,7 @@ <h5 id="filtering-on-the-consuming-side"><a class="anchor" href="#filtering-on-t
4233
4233
.stream(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> invoices</ span > < span class ="delimiter "> "</ span > </ span > )
4234
4234
.filter()
4235
4235
.values(filterValue) < i class ="conum " data-value ="1 "> </ i > < b > (1)</ b >
4236
- .filter (msg ->
4236
+ .postFilter (msg ->
4237
4237
filterValue.equals(msg.getApplicationProperties().get(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> state</ span > < span class ="delimiter "> "</ span > </ span > ))) < i class ="conum " data-value ="2 "> </ i > < b > (2)</ b >
4238
4238
.builder()
4239
4239
.messageHandler((ctx, msg) -> { })
@@ -4277,7 +4277,7 @@ <h5 id="filtering-on-the-consuming-side"><a class="anchor" href="#filtering-on-t
4277
4277
.filter()
4278
4278
.values(filterValue) < i class ="conum " data-value ="1 "> </ i > < b > (1)</ b >
4279
4279
.matchUnfiltered() < i class ="conum " data-value ="2 "> </ i > < b > (2)</ b >
4280
- .filter (msg ->
4280
+ .postFilter (msg ->
4281
4281
filterValue.equals(msg.getApplicationProperties().get(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> state</ span > < span class ="delimiter "> "</ span > </ span > ))
4282
4282
|| !msg.getApplicationProperties().containsKey(< span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> state</ span > < span class ="delimiter "> "</ span > </ span > ) < i class ="conum " data-value ="3 "> </ i > < b > (3)</ b >
4283
4283
)
@@ -4350,7 +4350,7 @@ <h4 id="using-native-epoll"><a class="anchor" href="#using-native-epoll"></a>Usi
4350
4350
< span class ="tag "> <dependency></ span >
4351
4351
< span class ="tag "> <groupId></ span > io.netty< span class ="tag "> </groupId></ span >
4352
4352
< span class ="tag "> <artifactId></ span > netty-transport-native-epoll< span class ="tag "> </artifactId></ span >
4353
- < span class ="tag "> <version></ span > 4.1.92 .Final< span class ="tag "> </version></ span >
4353
+ < span class ="tag "> <version></ span > 4.1.93 .Final< span class ="tag "> </version></ span >
4354
4354
< span class ="tag "> <classifier></ span > linux-x86_64< span class ="tag "> </classifier></ span >
4355
4355
< span class ="tag "> </dependency></ span >
4356
4356
@@ -4364,7 +4364,7 @@ <h4 id="using-native-epoll"><a class="anchor" href="#using-native-epoll"></a>Usi
4364
4364
< div class ="title "> Declaring the Linux x86-64 native < code > epoll</ code > transport dependency with Gradle</ div >
4365
4365
< div class ="content ">
4366
4366
< pre class ="CodeRay highlight "> < code data-lang ="groovy "> dependencies {
4367
- compile < span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> io.netty:netty-transport-native-epoll:4.1.92 .Final:linux-x86_64</ span > < span class ="delimiter "> "</ span > </ span >
4367
+ compile < span class ="string "> < span class ="delimiter "> "</ span > < span class ="content "> io.netty:netty-transport-native-epoll:4.1.93 .Final:linux-x86_64</ span > < span class ="delimiter "> "</ span > </ span >
4368
4368
}</ code > </ pre >
4369
4369
</ div >
4370
4370
</ div >
@@ -5382,8 +5382,8 @@ <h3 id="building-the-performance-tool"><a class="anchor" href="#building-the-per
5382
5382
</ div >
5383
5383
< div id ="footer ">
5384
5384
< div id ="footer-text ">
5385
- Version 0.10 .0-SNAPSHOT< br >
5386
- Last updated 2023-03-22 11:32:05 +0100
5385
+ Version 0.11 .0-SNAPSHOT< br >
5386
+ Last updated 2023-05-26 11:41:31 +0200
5387
5387
</ div >
5388
5388
</ div >
5389
5389
</ body >
0 commit comments