SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
4,279 Commits 28 Branches 0 Tags
main
Commit Graph

342 Commits

Author SHA1 Message Date
Oleg Zhurakousky
af820ee3c1 Initial 5.0 migration 2025-06-11 10:55:38 -04:00
spring-builds
a23dc7fe0a Going back to snapshots 2025-05-29 14:09:51 +00:00
spring-builds
88532ae040 Update SNAPSHOT to 4.3.0 2025-05-29 14:06:48 +00:00
spring-builds
57c0198979 Bumping versions to 4.3.1-SNAPSHOT after release 2025-05-29 00:10:54 +00:00
spring-builds
70b070d4e7 Going back to snapshots 2025-05-29 00:10:52 +00:00
spring-builds
e8ab3f9388 Update SNAPSHOT to 4.3.0 2025-05-29 00:07:17 +00:00
Oleg Zhurakousky
e6dc0bc342 GH-2814 Add version numbers of currently ruunning stream/function 
Version information is addedc to the standard Spring Boot banner

Resolves #2814
 2025-05-07 16:35:40 +02:00
spring-builds
1e401c8921 Going back to snapshots 2025-05-01 11:46:50 +00:00
spring-builds
b56b9f880b Update SNAPSHOT to 4.3.0-RC1 2025-05-01 11:44:19 +00:00
Oleg Zhurakousky
bfad60c609 GH-3030 Update phase of InputBindingLifecycle 2025-04-30 10:07:04 +02:00
Oleg Zhurakousky
2656bf7f4f GH-3083 Fix lifecycle of reactive producer 
Ensure that the corresponding FluxMessageChannel gets properly destroyed during application shutdown

Resolves #3083
 2025-04-30 08:59:54 +02:00
Oleg Zhurakousky
52913cef03 GH-3108 Fix links in docs 
Resolves #3108
 2025-04-22 15:11:53 +02:00
Oleg Zhurakousky
27c68b267b GH-3086 Fix naming for explicit bindings that are not backed by a function 2025-04-15 15:04:56 +02:00
Oleg Zhurakousky
4247670032 Fix formatting 2025-04-11 13:23:31 +02:00
spring-builds
18bc7d1fe7 Going back to snapshots 2025-04-07 10:26:31 +00:00
spring-builds
177f16745d Update SNAPSHOT to 4.3.0-M3 2025-04-07 10:24:02 +00:00
Oleg Zhurakousky
da58e42648 GH-3086 Define explicit defineInput/Output binding methods 
Also changed signature to return properties for convinience
Added test
 2025-04-04 15:21:58 +02:00
Oleg Zhurakousky
3261108285 GH-3086 Initial functionality to define bindings dynamically 2025-04-01 16:36:14 +02:00
Oleg Zhurakousky
1a01c6cbcc GH-3105 Fix hashCode calculation for StreamBridge function 
This would ensure that there are no collisions in hashCode calculation for cases where partitionKeyExpression is used in one of the bindings while partitionCount of any of the bindings may result in teh overall StreamBridge function having the same  hashCode

Resolves #3105
 2025-03-27 21:59:39 +01:00
Oleg Zhurakousky
91064171e2 GH-3101 Make Binder an instance variable 
Resolves #3101
 2025-03-25 15:12:01 +01:00
Oleg Zhurakousky
f48982971a Fix formatting 2025-03-24 23:41:15 +01:00
2tsumo-hitori
bb3324a5b5 Replaced ReentrantLock with ConcurrentHashMap.computeIfAbsent() 
to improve performance in StreamBridge.send() method.

- Avoids unnecessary locking overhead
- Improves concurrency and reduces contention
- Enhances throughput for high-load scenarios

Signed-off-by: 2tsumo-hitori <audghks1996@naver.com>
 2025-03-24 23:41:07 +01:00
Oleg Zhurakousky
8eebd773fc GH-3100 Move Brave and Actuator dependenies 
Moved Brane and Actuator dependencies from test-binder to integration tests under test scope

Resolves #3100
 2025-03-20 13:12:42 +01:00
spring-builds
a5c53f735f Going back to snapshots 2025-02-27 15:46:58 +00:00
spring-builds
1a4eadd8fe Update SNAPSHOT to 4.3.0-M2 2025-02-27 15:44:27 +00:00
Oleg Zhurakousky
afc8fa29da GH-3076 Change 'bindings' to ConcurrentHashMap in 'BindingServiceProperties' 
Using 'ConcurrentSkipListMap' was causing significant performance issues

Resolves #3076
 2025-02-26 08:39:00 +01:00
spencergibb
9889362f44 Formatting 2025-02-21 11:51:18 -05:00
Oleg Zhurakousky
c6c5e09c5d GH-3085 add test configuration file 2025-02-21 15:15:09 +01:00
Oleg Zhurakousky
3e624057a7 GH-3085 Add Number and Boolean Spel converter 
Refactor SpelConverter into an abstract class

Resolves #3085
 2025-02-21 15:05:51 +01:00
spencergibb
ea074ac414 Sets proxyBeanMethods = false on test config 2025-02-18 11:49:07 -05:00
Steven Gantz
25427bc718 Add additional test and error handling 
Handle when functionToInvoke returns null

add link to issue

Signed-off-by: Steven Gantz <steven.p.gantz@gmail.com>
 2025-02-10 20:59:43 -05:00
spring-builds
dc3669bfcf Going back to snapshots 2025-01-30 03:00:53 +00:00
spring-builds
4edccc3b56 Update SNAPSHOT to 4.3.0-M1 2025-01-30 02:58:18 +00:00
Oleg Zhurakousky
adddeffbf3 GH-3071 Add support for accessing producer/consumer properties 2025-01-28 09:36:58 +01:00
Soby Chacko
8954aaf336 Bumping next version to 4.3.0-SNAPSHOT 2025-01-17 11:06:07 -05:00
Artem Bilan
f259c55704 * Implement SmartLifecycle contract on the DefaultBinderFactory. 
When CRaC checkpoint is requested, the binder contexts must be stopped as well,
which includes all their managed beans, respectively.
 2025-01-07 14:22:23 -05:00
Oleg Zhurakousky
3f8b7003e7 GH-3054 Clear channel cache in StreamBridge during the refresh 
Resolves #3054
 2024-12-19 12:06:00 +01:00
spencergibb
637636dfa8 Adds @ConditionalOnMissingBean to test binder ObservationRegistry 2024-12-12 10:43:44 -05:00
Oleg Zhurakousky
aa2b309e66 GH-3030 Modify InputBindingLifecycle phase 
Resolves #3030
 2024-12-11 13:17:38 +01:00
Oleg Zhurakousky
1349adaba3 GH-3053 Fix regression with 'default' properties validation 
Resolves #3053
 2024-12-09 13:52:49 +01:00
Oleg Zhurakousky
c67fca58c4 GH-3052 Add to additional-spring-configuration-metadata.json 
Resolves #3052
 2024-12-04 16:16:44 +01:00
Agustino Lim
a88c34fc9f GH-3033: Register ObservationRegistry for Dynamic MessageChannels 
Fixes: gh-3033

* ensure `ObservationRegistry` is registered on dynamically created `MessageChannel` instances in `StreamBridge`
 2024-12-04 13:13:20 +01:00
spring-builds
f1e6c87814 Bumping versions to 4.2.1-SNAPSHOT after release 2024-12-03 00:21:56 +00:00
spring-builds
f03ea2582a Going back to snapshots 2024-12-03 00:21:54 +00:00
spring-builds
b26353cfcc Update SNAPSHOT to 4.2.0 2024-12-03 00:18:38 +00:00
Ömer Çelik
dccf8ae16a Message Channel should be closed in specified cases : application shutdown, unbinding or exceeding cache size. 
checkstyle fixes

Resolves #2869
Resolves #3026
 2024-11-18 14:07:48 +01:00
Fernando Blanch
a1c7773a82 Change order of the registry of sources classes after configuring Environment with all propertySources, so that sources classes can resolve conditions configurations. Fixes GH-3031 
Resolves #3032
 2024-11-18 11:36:22 +01:00
spring-builds
1b083c943e Going back to snapshots 2024-11-08 01:39:01 +00:00
spring-builds
34798150d8 Update SNAPSHOT to 4.2.0-RC1 2024-11-08 01:36:20 +00:00
Soby Chacko
e14bc1cb51 Revert "Adding Spring Cloud Stream Version To Message Headers For Easier Debugging Of Issues." 
This reverts commit a8fb34db0e.
 2024-11-05 16:50:08 -05:00