Commit Graph

1685 Commits

Author SHA1 Message Date
Oleg Zhurakousky
b711180841 Fix test to accomodate the related commit in s-c-function
s-c-function commit id - 40fe70d44c8649a0e1e688b3c65155c6217064b3
2021-10-25 14:13:52 +02:00
Oleg Zhurakousky
eb6394023e GH-2235 Fix partitioning issue for collection and add tests 2021-10-19 18:47:57 +02:00
Oleg Zhurakousky
7d156f3c28 Merge remote-tracking branch 'upstream/main' into main 2021-10-19 18:47:39 +02:00
Oleg Zhurakousky
a3414b77b7 GH-2235 clean up PartitionAwareFunctionWrapper 2021-10-19 18:29:06 +02:00
buildmaster
1fd283cfed Going back to snapshots 2021-10-19 09:02:22 +00:00
buildmaster
42abe2cae7 Update SNAPSHOT to 3.2.0-M3 2021-10-19 09:00:39 +00:00
Oleg Zhurakousky
ce6c09dea9 Disabling some tests 2021-10-19 10:57:35 +02:00
Tenzin Chemi
bd7302a8ec Minor doc fixes 2021-10-18 17:52:20 +02:00
Artem Bilan
f8a570a2cb Remove poller props in favor of Spring Boot
Starting with Spring Boot `2.6`, the auto-configuration
for Spring Integration introduces `poller` properties.
The `DefaultPollerProperties` and its respective `ChannelBindingAutoConfiguration` are not needed any more.

* Add `PollerConfigEnvironmentPostProcessor` to remap deprecated
`spring.cloud.stream.poller` into respective `spring.integration.poller`
properties
* Mention in the docs a deprecation move and its replacement

Related to: https://github.com/spring-projects/spring-boot/pull/27992
Resolves #2233
2021-10-18 16:07:21 +02:00
Oleg Zhurakousky
302a44ddb6 GH-2235 Fix partitioning support when output is a collection of messages 2021-10-15 19:29:14 +02:00
Oleg Zhurakousky
3d2921636b GH-2221 - Add internal caching to StreamBridge
Now, SB can actually cache its own function based on the output contentType, effectively creating single StreamBrdge function instance per output content type
ALso, disabled one failing test and fix the polling change introduced by Spring Boot

Resolves #2221
2021-10-07 17:04:04 +02:00
Oleg Zhurakousky
633bc7b168 GH-2229 behavior of when there is a single function bean in context
Resolves #2229
2021-10-06 11:04:28 +02:00
buildmaster
b44e55d247 Going back to snapshots 2021-10-01 13:41:23 +00:00
buildmaster
b174cb4a32 Update SNAPSHOT to 3.2.0-M2 2021-10-01 13:38:47 +00:00
Soby Chacko
5171bbe0ac GH-2225: Native changes required
Remove autorwiring application context in BindableFunctionProxyFactory.
Use bean factory directly instead.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2225
2021-09-21 18:19:34 -04:00
Oleg Zhurakousky
7cd4bb86d6 Fix test 2021-08-28 10:00:59 +02:00
Oleg Zhurakousky
83d23fda58 GH-2218 Fix support for multiple consumers to the same destination
This fix implies that a single error infristructure will be shared by such consumers

Resolves #2218
2021-08-28 09:51:38 +02:00
buildmaster
c5a58f0fc1 Going back to snapshots 2021-07-30 14:52:58 +00:00
buildmaster
174b973d8f Update SNAPSHOT to 3.2.0-M1 2021-07-30 14:51:14 +00:00
Oleg Zhurakousky
43f84be4c0 GH-2202 Remove Reflection calls for adding MessageConverters
Resolves #2202
2021-07-26 13:52:47 +02:00
Oleg Zhurakousky
aa3b0675c7 GH-2196 Enhance test case to demonstrate StreamBridge with multiple partitioned producers
Resolves #2196
2021-07-16 15:25:26 +02:00
Oleg Zhurakousky
70feca33ec Bump timeout on randomly failing test 2021-07-16 10:04:02 +02:00
Oleg Zhurakousky
57816b1920 Fix test 2021-07-16 09:59:29 +02:00
Oleg Zhurakousky
6036a9695b Fix POMs for 3.2 2021-07-13 16:32:40 +02:00
Oleg Zhurakousky
9b6388fb9c Switch main to 3.2 2021-07-13 14:56:18 +02:00
Oleg Zhurakousky
ac5124dabf JUnit 5 migration related to boot 2.6 2021-07-13 13:09:26 +02:00
Oleg Zhurakousky
6be9c461a5 Ensure StreamBridge function is always wrapped 2021-07-05 13:29:25 +02:00
Oleg Zhurakousky
32a8b9eec8 Add support for SCF-GH-711 source/target types determination 2021-07-01 17:26:18 +02:00
Oleg Zhurakousky
8cae6f13b2 GH-2101 Fix StreamBridge when sending Message with native encoding
There was an always cast to FunctionInvocationWrapper even though in the case of nativeEncoding the function was not of that instance. This fixes it.

Resolves #2101
2021-06-29 15:07:40 +02:00
Oleg Zhurakousky
b17bcb90f1 GH-2129 Polishing test 2021-06-29 14:44:42 +02:00
Oleg Zhurakousky
15824cfdb0 GH-2129 Ensure exception is propagated from ApplicationJsonMessageMarshallingConverter
This will ensure that any exception that is thrown during the conversion by ApplicationJsonMessageMarshallingConverter are propagated. Basically the idea is that since MessageConverter has accepted the conversion via canConvert() method it is no longer necessary to expect that may be some other converter in the stack may succeed. And on top of that user can still define custom message converter

Resolves #2129
Resolves #2191
2021-06-29 12:48:17 +02:00
Oleg Zhurakousky
89e09afa74 GH-2151 Document ProducerMessageHandlerCustomizer
Resolves #2151
2021-06-29 12:00:24 +02:00
Oleg Zhurakousky
8c88cf14d8 GH-2179 provide mechanism to remove short-lived headers
Headers such as 'spring.cloud.stream.sendto.destination' are no longer valid once the message has been sent, os it will be removed

Resolves #2179
2021-06-28 15:47:06 +02:00
Oleg Zhurakousky
86535d10b9 GH-2189 Ensure SpelExpressionConverterConfiguration class is added
This ensures that SpelExpressionConverterConfiguration is added for cases where multiple binders are used

Resolves #2189
2021-06-28 14:31:08 +02:00
Soby Chacko
76c0a2488b StreamBridge and ChannelInterceptors enhancements
Currently, when `StreamBridge` creates an output binding, the framework
applies all the available channel interceptors on it by default. This
creates unwanted side effects and the application does not have a way
to control this. Change this behavior by only applying channel interceptors
annoatated with `@GlobalChannelInterceptor`. This way, the user can
provide patterns to decide which interceptors need to be applied on
specific `StreamBridge` bindings.

Adding tests to verify.

Adding docs.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2180
2021-06-11 16:44:41 +02:00
LiangYong
71f1af3c51 fix document example code missing semicolon issue 2021-06-08 15:21:08 -04:00
Oleg Zhurakousky
49dc1f9ff9 Disable test 2021-06-02 16:46:59 +02:00
Oleg Zhurakousky
e17339195b Disable test 2021-06-02 16:31:24 +02:00
Oleg Zhurakousky
5fa653c808 Disable test 2021-06-02 16:29:44 +02:00
Oleg Zhurakousky
f6be741dba Fix test 2021-06-02 16:22:10 +02:00
Oleg Zhurakousky
2797463e56 Update s-c-function to 3.1.4-SNAPSHOT 2021-05-27 08:57:32 +02:00
buildmaster
2f90a08f0b Bumping versions to 3.1.4-SNAPSHOT after release 2021-05-26 15:24:55 +00:00
buildmaster
fe163257fa Going back to snapshots 2021-05-26 15:24:54 +00:00
buildmaster
50ba1b08a7 Update SNAPSHOT to 3.1.3 2021-05-26 15:22:18 +00:00
Oleg Zhurakousky
ab5471d509 Update pom.xml 2021-05-26 17:10:37 +02:00
Oleg Zhurakousky
f49bc19820 GH-2114 Change the name of the variable hwen specifying binder name in StreamBridge 2021-05-25 19:35:44 +02:00
Oleg Zhurakousky
70537b924e GH-2164 Update documentation
Remove obsolete docs and add deprecations and update what's new section

Resolves #2164
2021-05-25 14:53:08 +02:00
Oleg Zhurakousky
2677035779 GH-2114 Add support for multiple binders to StreamBridge
Resolves #2114
2021-05-25 14:33:25 +02:00
Oleg Zhurakousky
717a8e4f8b polish docs
Resolves #2150
2021-05-25 12:51:38 +02:00
Ильиных Илья Сергеевич
245e80ab52 Fixed spring-cloud-stream.adoc documentation rendering 2021-05-25 12:50:22 +02:00