Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
11,779 Commits 25 Branches 0 Tags
2e60eb657e75550f2a09db3117bc9f8d0c4ecea1
Commit Graph

11779 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Artem Bilan
2e60eb657e Migrate ReturnAddressTests to JUnit 5 
Looks like `ApplicaitonContext.stop()` is note called on `close()`.
This might cause an `OutOfMemoryError` on the CI

* Use Spring context configuration for the test environment

(cherry picked from commit b2a3d25ffd)
 2024-07-18 11:13:51 -04:00
Spring Builds
38b6cd832b [artifactory-release] Next development version 2024-07-16 17:17:20 +00:00
Spring Builds
d79eadfaa0 [artifactory-release] Release version 6.2.7 2024-07-16 17:17:16 +00:00
dependabot[bot]
6cdfae0787 Bump org.springframework.graphql:spring-graphql from 1.2.7 to 1.2.8 (#9343) 
Bumps [org.springframework.graphql:spring-graphql](https://github.com/spring-projects/spring-graphql) from 1.2.7 to 1.2.8.
- [Release notes](https://github.com/spring-projects/spring-graphql/releases)
- [Commits](https://github.com/spring-projects/spring-graphql/compare/v1.2.7...v1.2.8)

---
updated-dependencies:
- dependency-name: org.springframework.graphql:spring-graphql
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-16 16:54:49 +00:00
dependabot[bot]
5f2398ea75 Bump org.springframework.kafka:spring-kafka-bom from 3.1.6 to 3.1.7 (#9339) 
Bumps [org.springframework.kafka:spring-kafka-bom](https://github.com/spring-projects/spring-kafka) from 3.1.6 to 3.1.7.
- [Release notes](https://github.com/spring-projects/spring-kafka/releases)
- [Commits](https://github.com/spring-projects/spring-kafka/compare/v3.1.6...v3.1.7)

---
updated-dependencies:
- dependency-name: org.springframework.kafka:spring-kafka-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-16 16:47:29 +00:00
dependabot[bot]
3984c5c538 Bump graalvmVersion from 23.0.4 to 23.0.5 (#9341) 
Bumps `graalvmVersion` from 23.0.4 to 23.0.5.

Updates `org.graalvm.sdk:graal-sdk` from 23.0.4 to 23.0.5
- [Release notes](https://github.com/oracle/graal/releases)
- [Commits](https://github.com/oracle/graal/commits)

Updates `org.graalvm.js:js` from 23.0.4 to 23.0.5
- [Release notes](https://github.com/graalvm/graaljs/releases)
- [Changelog](https://github.com/oracle/graaljs/blob/master/CHANGELOG.md)
- [Commits](https://github.com/graalvm/graaljs/commits)

---
updated-dependencies:
- dependency-name: org.graalvm.sdk:graal-sdk
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.graalvm.js:js
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-16 15:46:48 +00:00
Artem Bilan
0854d4b5f1 GH-9335: Fix MicrometerNodeEnhancer for a primary MeterRegistry bean 
Fixes: #9335

Spring Boot provides a `CompositeMeterRegistry` bean marked with a `@Primary`.
So, this one has to be autowired whenever we would like to deal with application
environment.
The `MicrometerNodeEnhancer` has a flaw to skip `MeterRegistry` injection if we have more than one `MeterRegistry` bean.

* Fix `MicrometerNodeEnhancer` logic to use `ObjectProvider.getIfUnique()` API
which is able to deal with the `primary` properly.
Otherwise, `null` as it was before

(cherry picked from commit e0472d887a)
 2024-07-16 15:16:53 +00:00
dependabot[bot]
102ac08016 Bump org.springframework.retry:spring-retry from 2.0.6 to 2.0.7 (#9330) 
Bumps [org.springframework.retry:spring-retry](https://github.com/spring-projects/spring-retry) from 2.0.6 to 2.0.7.
- [Release notes](https://github.com/spring-projects/spring-retry/releases)
- [Commits](https://github.com/spring-projects/spring-retry/compare/v2.0.6...v2.0.7)

---
updated-dependencies:
- dependency-name: org.springframework.retry:spring-retry
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 02:24:23 +00:00
dependabot[bot]
02c02ae991 Bump io.micrometer:micrometer-tracing-bom from 1.2.7 to 1.2.8 (#9327) 
Bumps [io.micrometer:micrometer-tracing-bom](https://github.com/micrometer-metrics/tracing) from 1.2.7 to 1.2.8.
- [Release notes](https://github.com/micrometer-metrics/tracing/releases)
- [Commits](https://github.com/micrometer-metrics/tracing/compare/v1.2.7...v1.2.8)

---
updated-dependencies:
- dependency-name: io.micrometer:micrometer-tracing-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 02:21:47 +00:00
dependabot[bot]
9089ac2d20 Bump org.springframework:spring-framework-bom from 6.1.10 to 6.1.11 (#9328) 
Bumps [org.springframework:spring-framework-bom](https://github.com/spring-projects/spring-framework) from 6.1.10 to 6.1.11.
- [Release notes](https://github.com/spring-projects/spring-framework/releases)
- [Commits](https://github.com/spring-projects/spring-framework/compare/v6.1.10...v6.1.11)

---
updated-dependencies:
- dependency-name: org.springframework:spring-framework-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 02:06:54 +00:00
Swiss Chris
4dc43e84f0 Fix endpoint default timeout in global-properties.adoc 
Fixes: #9314

(cherry picked from commit 487a60e79a)
 2024-07-14 02:00:51 +00:00
dependabot[bot]
de96ca9d44 Bump io.projectreactor:reactor-bom from 2023.0.7 to 2023.0.8 (#9331) 
Bumps [io.projectreactor:reactor-bom](https://github.com/reactor/reactor) from 2023.0.7 to 2023.0.8.
- [Release notes](https://github.com/reactor/reactor/releases)
- [Commits](https://github.com/reactor/reactor/compare/2023.0.7...2023.0.8)

---
updated-dependencies:
- dependency-name: io.projectreactor:reactor-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 00:57:42 +00:00
dependabot[bot]
bf91152170 Bump org.springframework.data:spring-data-bom from 2023.1.7 to 2023.1.8 (#9332) 
Bumps [org.springframework.data:spring-data-bom](https://github.com/spring-projects/spring-data-bom) from 2023.1.7 to 2023.1.8.
- [Release notes](https://github.com/spring-projects/spring-data-bom/releases)
- [Commits](https://github.com/spring-projects/spring-data-bom/compare/2023.1.7...2023.1.8)

---
updated-dependencies:
- dependency-name: org.springframework.data:spring-data-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 00:50:27 +00:00
dependabot[bot]
69dbb1097d Bump io.micrometer:micrometer-bom from 1.12.7 to 1.12.8 (#9329) 
Bumps [io.micrometer:micrometer-bom](https://github.com/micrometer-metrics/micrometer) from 1.12.7 to 1.12.8.
- [Release notes](https://github.com/micrometer-metrics/micrometer/releases)
- [Commits](https://github.com/micrometer-metrics/micrometer/compare/v1.12.7...v1.12.8)

---
updated-dependencies:
- dependency-name: io.micrometer:micrometer-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 00:48:42 +00:00
dependabot[bot]
349239e351 Bump the development-dependencies group with 3 updates (#9326) 
Bumps the development-dependencies group with 3 updates: org.apache.tomcat.embed:tomcat-embed-websocket, io.spring.dependency-management and com.github.spotbugs.


Updates `org.apache.tomcat.embed:tomcat-embed-websocket` from 10.1.25 to 10.1.26

Updates `io.spring.dependency-management` from 1.1.5 to 1.1.6

Updates `com.github.spotbugs` from 6.0.18 to 6.0.19

---
updated-dependencies:
- dependency-name: org.apache.tomcat.embed:tomcat-embed-websocket
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
- dependency-name: io.spring.dependency-management
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
- dependency-name: com.github.spotbugs
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-14 00:48:08 +00:00
Artem Bilan
481bb2ca80 Migrate release notification to Google Chat 
(cherry picked from commit 13a113cf66)
 2024-07-11 18:49:57 +00:00
Artem Bilan
865952d79d Add pluginManagement into settings.gradle 
(cherry picked from commit c9f4d7e52a)
 2024-07-08 14:11:47 +00:00
Artem Bilan
876afa48d2 Migrate to io.spring.develocity.conventions plugin 
(cherry picked from commit 9bb353ad9a)
 2024-07-08 14:06:51 +00:00
Artem Bilan
4367ab772a GH-9294: Set permissions to target file on rename 
* GH-9294: Set permissions to target file on rename

Fixes: #9294

When the `deleteSourceFiles` property of `FileWritingMessageHandler` is `true`, the `chmod` is not set on the target file.

* Fix `FileWritingMessageHandler.handleFileMessage()` logic to `setPermissions(resultFile)` after `move` operation

* * Set only `OWNER_READ` permission for file in unit test

(cherry picked from commit 3e71ea5521)
 2024-07-08 14:03:29 +00:00
dependabot[bot]
9a81395518 Bump org.apache.groovy:groovy-bom from 4.0.21 to 4.0.22 (#9308) 
Bumps [org.apache.groovy:groovy-bom](https://github.com/apache/groovy) from 4.0.21 to 4.0.22.
- [Commits](https://github.com/apache/groovy/commits)

---
updated-dependencies:
- dependency-name: org.apache.groovy:groovy-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-07 00:48:41 +00:00
dependabot[bot]
412b122310 Bump org.jruby:jruby-complete from 9.4.7.0 to 9.4.8.0 (#9307) 
Bumps org.jruby:jruby-complete from 9.4.7.0 to 9.4.8.0.

---
updated-dependencies:
- dependency-name: org.jruby:jruby-complete
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-07 00:48:11 +00:00
Artem Bilan
71f74be1d1 GH-9297: Improve ImapIdleChannelAdapter.callIdle() for cause 
Fixes: #9297

For a normal `jakarta.mail.StoreClosedException: * BYE Jakarta Mail Exception: java.net.SocketException: Connection reset`
 the `ImapIdleChannelAdapter.callIdle()` results in a resubmission (and reconnection)
 with logging 'Failed to execute IDLE task. Will attempt to resubmit in 10000 milliseconds.'`
However, when `selectorExpression` is in used and that one is based on mail `Message` object,
we may fail with `FolderClosedException` which is wrapped to the `SpelEvaluationException` and some
other stack traces.
So, `jakarta.mail.MessagingException` might be deep in the cause chain.

* Fix `ImapIdleChannelAdapter` via introducing `getJakartaMailMessagingExceptionFromCause()` utility
method which searches for the `jakarta.mail.MessagingException` in cause chain.
* Rework `ImapIdleChannelAdapter.callIdle()` logic to rely on this new method

(cherry picked from commit 272fcd044d)
 2024-07-02 19:39:54 +00:00
dependabot[bot]
cc27593e0a Bump org.junit:junit-bom from 5.10.2 to 5.10.3 (#9287) 
Bumps [org.junit:junit-bom](https://github.com/junit-team/junit5) from 5.10.2 to 5.10.3.
- [Release notes](https://github.com/junit-team/junit5/releases)
- [Commits](https://github.com/junit-team/junit5/compare/r5.10.2...r5.10.3)

---
updated-dependencies:
- dependency-name: org.junit:junit-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-07-01 17:19:50 +00:00
darrylsmithUGA
0e7a4a1536 GH-9272: Close ClientSession from SftpSession 
Fixes: #9272

* close ClientSession when closing SftpSession
* fix whitespace issues
* stop the SshClient on bean destruction
* use convenient assertions

(cherry picked from commit a3fb68a831)
 2024-07-01 17:02:56 +00:00
Artem Bilan
4ead95466b GH-9259: Fix Reactor context propagation on reactive reply (#9284) 
Fixes: #9259

The `Mono.toFuture()` does not propagate context to thread locals of the `CompletableFuture` consumer.
See `MonoToCompletableFuture`

* Fix `AbstractMessageProducingHandler` to convert reply `Mono` to `CompletableFuture` manually.
Use `doOnEach()` and set thread locals from the Reactor context manually around `replyFuture.complete()/completeExceptionally()`
* Add respective unit test into `WebFluxObservationPropagationTests` to ensure that same trace is used in downstream endpoints after WebFlux client reply

(cherry picked from commit 4a77dbcc46)
 2024-06-28 18:02:04 +00:00
Artem Bilan
0b07c12025 GH-9276: Mitigate ConcurrentModificationException in the Mqttv5PahoMessageDrivenChannelAdapter 
Fixes: #9276

The current Eclipse Paho client has wrong removal from map logic which leads to the
`ConcurrentModificationException` when we unsubscribe from topic.

* Catch a `ConcurrentModificationException` `this.mqttClient.unsubscribe()` and just log it as an `error`

(cherry picked from commit 12fc353db1)

# Conflicts:
#	spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/Mqttv5PahoMessageDrivenChannelAdapter.java
 2024-06-26 14:29:57 -04:00
Artem Bilan
e99acd85cb GH-9260: Fix IntegrationManagementConfiguration.obtainObservationPatterns() logic 
Fixes: #9260

The current `IntegrationManagementConfiguration.obtainObservationPatterns()` is to always have an `*` as a first
pattern in the final result.
Because of `HashSet` natural order.
This would lead to ignore all the patterns, especially those with negation

* Fix `IntegrationManagementConfiguration.obtainObservationPatterns()` logic to ignore regular
patterns if `*` is present.
Optimization wise.
* Always put `*` into the end of final array let negative patterns to do their job
* Modify `IntegrationGraphServerTests` & `WebFluxObservationPropagationTests`
test configurations to ensure that `*` pattern does not have a precedence over negative patterns.

(cherry picked from commit 4108ea520e)
 2024-06-25 20:26:06 +00:00
Artem Bilan
f997de4855 Revise subscribed state in the FluxMessageChannel 
The `Sinks.Many<Boolean> subscribedSignal` is a bit of overhead in the logic.

* Use `Mono.fromCallable(this.sink::currentSubscriberCount)` instead for `delaySubscription()`
when we perform `subscribeTo(Publisher)`

(cherry picked from commit bdcb856a90)
 2024-06-25 18:47:40 +00:00
Artem Bilan
d1a80fddb0 GH-9268: Fix regression in SMB Inbound for sub-dirs 
Fixes: #9268

The new `SmbSession.list()` behavior prevents to pull files from sub-folders in inbound channel adapter

* Fix `SmbSession.list()` similar way to `SftpSession`: if `remoteFile.isFile()` then remove it as is.
Otherwise, perform `smbDir.listFiles()` on that sub-dir
* Modify `SmbTests.testSmbInboundFlow()` to poll files from the `smbSource/subSmbSource/`

(cherry picked from commit f2399a4e13)
 2024-06-24 18:52:38 +00:00
dependabot[bot]
a730799493 Bump org.springframework:spring-framework-bom from 6.1.9 to 6.1.10 (#9267) 
Bumps [org.springframework:spring-framework-bom](https://github.com/spring-projects/spring-framework) from 6.1.9 to 6.1.10.
- [Release notes](https://github.com/spring-projects/spring-framework/releases)
- [Commits](https://github.com/spring-projects/spring-framework/compare/v6.1.9...v6.1.10)

---
updated-dependencies:
- dependency-name: org.springframework:spring-framework-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-24 16:26:24 +00:00
dependabot[bot]
3be80baf86 Bump the development-dependencies group with 2 updates (#9266) 
Bumps the development-dependencies group with 2 updates: org.apache.tomcat.embed:tomcat-embed-websocket and com.github.spotbugs.


Updates `org.apache.tomcat.embed:tomcat-embed-websocket` from 10.1.24 to 10.1.25

Updates `com.github.spotbugs` from 6.0.17 to 6.0.18

---
updated-dependencies:
- dependency-name: org.apache.tomcat.embed:tomcat-embed-websocket
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
- dependency-name: com.github.spotbugs
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-23 00:46:14 +00:00
Spring Builds
025876e580 [artifactory-release] Next development version 2024-06-18 17:57:21 +00:00
Spring Builds
77ce882097 [artifactory-release] Release version 6.2.6 2024-06-18 17:57:17 +00:00
dependabot[bot]
a1973a7c12 Bump org.springframework.graphql:spring-graphql from 1.2.6 to 1.2.7 (#9258) 
Bumps [org.springframework.graphql:spring-graphql](https://github.com/spring-projects/spring-graphql) from 1.2.6 to 1.2.7.
- [Release notes](https://github.com/spring-projects/spring-graphql/releases)
- [Commits](https://github.com/spring-projects/spring-graphql/compare/v1.2.6...v1.2.7)

---
updated-dependencies:
- dependency-name: org.springframework.graphql:spring-graphql
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-18 17:40:27 +00:00
dependabot[bot]
7d3ea09fd1 Bump org.springframework.kafka:spring-kafka-bom from 3.1.5 to 3.1.6 (#9255) 
Bumps [org.springframework.kafka:spring-kafka-bom](https://github.com/spring-projects/spring-kafka) from 3.1.5 to 3.1.6.
- [Release notes](https://github.com/spring-projects/spring-kafka/releases)
- [Commits](https://github.com/spring-projects/spring-kafka/compare/v3.1.5...v3.1.6)

---
updated-dependencies:
- dependency-name: org.springframework.kafka:spring-kafka-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-18 17:27:27 +00:00
dependabot[bot]
76c4f6aad2 Bump org.springframework.security:spring-security-bom (#9256) 
Bumps [org.springframework.security:spring-security-bom](https://github.com/spring-projects/spring-security) from 6.2.4 to 6.2.5.
- [Release notes](https://github.com/spring-projects/spring-security/releases)
- [Changelog](https://github.com/spring-projects/spring-security/blob/main/RELEASE.adoc)
- [Commits](https://github.com/spring-projects/spring-security/compare/6.2.4...6.2.5)

---
updated-dependencies:
- dependency-name: org.springframework.security:spring-security-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-18 15:52:00 +00:00
dependabot[bot]
6169d52f18 Bump org.springframework.amqp:spring-amqp-bom from 3.1.5 to 3.1.6 (#9254) 
Bumps [org.springframework.amqp:spring-amqp-bom](https://github.com/spring-projects/spring-amqp) from 3.1.5 to 3.1.6.
- [Release notes](https://github.com/spring-projects/spring-amqp/releases)
- [Commits](https://github.com/spring-projects/spring-amqp/compare/v3.1.5...v3.1.6)

---
updated-dependencies:
- dependency-name: org.springframework.amqp:spring-amqp-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-18 15:38:01 +00:00
dependabot[bot]
8c3d57cc3f Bump org.springframework:spring-framework-bom from 6.1.8 to 6.1.9 (#9239) 
Bumps [org.springframework:spring-framework-bom](https://github.com/spring-projects/spring-framework) from 6.1.8 to 6.1.9.
- [Release notes](https://github.com/spring-projects/spring-framework/releases)
- [Commits](https://github.com/spring-projects/spring-framework/compare/v6.1.8...v6.1.9)

---
updated-dependencies:
- dependency-name: org.springframework:spring-framework-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-17 15:03:35 +00:00
dependabot[bot]
b39aef5080 Bump com.gradle.develocity from 3.17.4 to 3.17.5 (#9238) 
Bumps com.gradle.develocity from 3.17.4 to 3.17.5.

---
updated-dependencies:
- dependency-name: com.gradle.develocity
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 02:01:15 +00:00
dependabot[bot]
446625efda Bump io.projectreactor:reactor-bom from 2023.0.6 to 2023.0.7 (#9242) 
Bumps [io.projectreactor:reactor-bom](https://github.com/reactor/reactor) from 2023.0.6 to 2023.0.7.
- [Release notes](https://github.com/reactor/reactor/releases)
- [Commits](https://github.com/reactor/reactor/compare/2023.0.6...2023.0.7)

---
updated-dependencies:
- dependency-name: io.projectreactor:reactor-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 01:25:16 +00:00
dependabot[bot]
1c76ab3bad Bump org.springframework.data:spring-data-bom from 2023.1.6 to 2023.1.7 (#9241) 
Bumps [org.springframework.data:spring-data-bom](https://github.com/spring-projects/spring-data-bom) from 2023.1.6 to 2023.1.7.
- [Release notes](https://github.com/spring-projects/spring-data-bom/releases)
- [Commits](https://github.com/spring-projects/spring-data-bom/compare/2023.1.6...2023.1.7)

---
updated-dependencies:
- dependency-name: org.springframework.data:spring-data-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 01:18:38 +00:00
dependabot[bot]
21560b1a09 Bump the development-dependencies group with 2 updates (#9237) 
Bumps the development-dependencies group with 2 updates: [org.hibernate.orm:hibernate-core](https://github.com/hibernate/hibernate-orm) and com.github.spotbugs.


Updates `org.hibernate.orm:hibernate-core` from 6.4.8.Final to 6.4.9.Final
- [Release notes](https://github.com/hibernate/hibernate-orm/releases)
- [Changelog](https://github.com/hibernate/hibernate-orm/blob/6.4.9/changelog.txt)
- [Commits](https://github.com/hibernate/hibernate-orm/compare/6.4.8...6.4.9)

Updates `com.github.spotbugs` from 6.0.15 to 6.0.17

---
updated-dependencies:
- dependency-name: org.hibernate.orm:hibernate-core
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
- dependency-name: com.github.spotbugs
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: development-dependencies
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 01:14:00 +00:00
dependabot[bot]
78d2580331 Bump io.micrometer:micrometer-tracing-bom from 1.2.6 to 1.2.7 (#9243) 
Bumps [io.micrometer:micrometer-tracing-bom](https://github.com/micrometer-metrics/tracing) from 1.2.6 to 1.2.7.
- [Release notes](https://github.com/micrometer-metrics/tracing/releases)
- [Commits](https://github.com/micrometer-metrics/tracing/compare/v1.2.6...v1.2.7)

---
updated-dependencies:
- dependency-name: io.micrometer:micrometer-tracing-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 00:48:57 +00:00
dependabot[bot]
febb41cf12 Bump io.micrometer:micrometer-bom from 1.12.6 to 1.12.7 (#9240) 
Bumps [io.micrometer:micrometer-bom](https://github.com/micrometer-metrics/micrometer) from 1.12.6 to 1.12.7.
- [Release notes](https://github.com/micrometer-metrics/micrometer/releases)
- [Commits](https://github.com/micrometer-metrics/micrometer/compare/v1.12.6...v1.12.7)

---
updated-dependencies:
- dependency-name: io.micrometer:micrometer-bom
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2024-06-16 00:31:19 +00:00
Kevin Van keer
069fa9ffa0 GH-9230 fix error in code snippet 
Fixes: #9230

Some code was present in the code snippet that shouldn't be there.

(cherry picked from commit 3d66ea00d9)
 2024-06-12 14:49:00 +00:00
Alessio Matricardi
ac29b2673e GH-9197: Optional ZeroMQ topic wrapping 
Fixes: #9197

* Update `ZeroMqMessageHandler` for `wrapTopic` option
* Add author, fix code style, add same logic also for `ZeroMqMessageProducer`
* Add `wrapTopic` function also in DSL specs
* Fix wrap topic test: duplicate socket address caused binding exception
* Rewrite the `MessageProducer.wrapTopic()` test
* Call `stop()` instead of `destroy()` method

(cherry picked from commit 80c8a61f33)
 2024-06-10 14:56:26 +00:00
Artem Bilan
460a4b670b GH-9191: Support byte[] for headers in the MessageReceiverContext 
Fixes: #9191

Not all inbound protocol handlers convert header from native representation.
Sometimes they just come in as `byte[]`.

* Fix `MessageReceiverContext` to support `byte[]` for headers used in the observation,
e.g. `B3-*`, `traceparent` etc.

(cherry picked from commit b29ff9a710)
 2024-06-07 14:00:15 +00:00
Artem Bilan
7882609102 GH-9214: Fix subscription identifier logic in Mqttv5PahoMessageDrivenChannelAdapter 
Fixes: #9214

The `MqttAsyncClient` can set `subscriptionIdentifier` from session if it is enabled
and available from connection

* Remove manual `subscriptionIdentifierCounter` from the `Mqttv5PahoMessageDrivenChannelAdapter`.
Instead, use `subscriptionProperties.setSubscriptionIdentifiers(List.of(0));`
to make the `this.mqttSession.getNextSubscriptionIdentifier();` to work
when `if (connOpts.useSubscriptionIdentifiers() && this.mqttConnection.isSubscriptionIdentifiersAvailable()) {` is `true`

(cherry picked from commit 3dcbdef330)

# Conflicts:
#	spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/Mqttv5PahoMessageDrivenChannelAdapter.java
 2024-06-06 12:16:08 -04:00
Artem Bilan
bf6c4f6157 GH-9215: Honor back-pressure in FluxMessageChannel 
Fixes: #9215

* Instead of `share()` use `publish(1).refCount()` to prefetch only item from upstream.
* Also remove `publishOn(this.scheduler)` for upstream publishers in favor of opt-in on the consumer side.

(cherry picked from commit e9561b41f1)
 2024-06-06 15:39:11 +00:00
Artem Bilan
d22737ccb0 GH-9211: Fix SmbSession.get() 
Fixes: #9211

The `AbstractRemoteFileOutboundGateway.get()` uses `Session.list()` for the provided remote file name.
The `SmbSession` does not support listing for a single file.

* Add logic into `SmbSession.list()` similar to `SftpSession.list()` to list a single remote file
on the provided path

(cherry picked from commit 91de12c786)
 2024-06-05 15:04:02 +00:00