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

1702 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Oleg Zhurakousky
abefd534f9 Fix spelling errors in doc 2021-12-01 11:03:50 +01:00
Oleg Zhurakousky
ec2422418b GH-2213 Add docs to clarify SpEL usage 
Resolves #2213
 2021-11-30 14:04:10 +01:00
Eugen Cristea
f860177381 Content Type Negotiation 
message handler example fix
 2021-11-30 11:15:28 +01:00
Oleg Zhurakousky
bb4064d883 GH-2090 Fix wild card contentType processing in StreamBridge 
This fix is dependent on https://github.com/spring-cloud/spring-cloud-function/issues/773

Resolves #2090
 2021-11-29 19:14:35 +01:00
Soby Chacko
ada1f4c3a5 GH-2245 StreamBridge partitioning fix 
Fix the order in applying partitioning interceptor in StreamBridge.
The interceptor must be added before the call for binding the producer.

Related to resolving https://github.com/spring-cloud/spring-cloud-stream/issues/2245

Specifically for this: https://github.com/spring-cloud/spring-cloud-stream/issues/2245#issuecomment-977663452
 2021-11-25 10:08:56 -05:00
Oleg Zhurakousky
241e57417f Fix ApplicationJsonMessageMarshallingConverter String conversion 2021-11-25 09:45:41 -05:00
Oleg Zhurakousky
d1358789b9 GH-2245 Ensure DefaultPartitionInterceptor is added to partitioned destinations managed by StreamBridge 
Resolves #2245
 2021-11-16 14:06:44 +01:00
Oleg Zhurakousky
4e011c26f3 GH-2206 Add resetLastError method to TestChannelBinder 
Resolves #2206
 2021-11-03 16:51:53 +01:00
Oleg Zhurakousky
a2495bc920 GH-2243 Document spring.cloud.stream.dynamic-destination-cache-size property 
Resolves #2243
 2021-11-03 16:31:07 +01:00
buildmaster
67d20e8367 Going back to snapshots 2021-11-03 08:36:00 +00:00
buildmaster
470b42d4d2 Update SNAPSHOT to 3.2.0-RC1 2021-11-03 08:34:20 +00:00
Soby Chacko
ac33329260 Remove schema registry references from the docs 2021-11-02 15:43:05 +01:00
Oleg Zhurakousky
afe8045493 GH-2212 Additional fixes related to lifecycle control over components that rely on SPCA 2021-10-27 19:29:22 +02:00
Oleg Zhurakousky
0a675e3534 GH-2215 Ensure internal components reuse ObjectMapper 
Resolves #2215
 2021-10-27 19:06:43 +02:00
Oleg Zhurakousky
662d126e4f Polishing 2021-10-27 17:23:21 +02:00
Oleg Zhurakousky
97b7db0865 GH-2212 Fix Lifecycle control over components that rely on SPCA 
This fixes the condition when startiing/stopping message producers which themselves are controlled by SourcsPollingChannelAdapter which we must also start/stop

Resolves #2212
 2021-10-27 17:22:14 +02:00
Nitin
fd757cb124 Update README.adoc 2021-10-26 15:38:18 +02:00
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