SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,607 Commits 28 Branches 0 Tags
3.0.x
Commit Graph

1607 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Oleg Zhurakousky
5cb8f5e9fa Fix snapshot versions 2021-07-08 15:15:13 +02:00
buildmaster
83bd952dd5 Bumping versions to 3.0.14.SNAPSHOT after release 2021-07-05 13:43:14 +00:00
buildmaster
e54b63c6e4 Going back to snapshots 2021-07-05 13:43:13 +00:00
buildmaster
c106e24492 Update SNAPSHOT to 3.0.13.RELEASE 2021-07-05 13:40:30 +00:00
Oleg Zhurakousky
114c6e1414 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:19:20 +02:00
Oleg Zhurakousky
262c088b94 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:49:06 +02:00
Oleg Zhurakousky
b5dd33cc3c 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
 2021-06-28 15:55:20 +02:00
Soby Chacko
311a9f1edc Update to 3.0.13.BUILD-SNAPSHOT 2021-05-05 12:01:03 -04:00
Oleg Zhurakousky
199de41433 GH-2160 Fix NPE in MessageConverterConfigurer 
Resolves #2160
 2021-05-05 15:52:19 +02:00
buildmaster
472b080619 Bumping versions to 3.0.13.SNAPSHOT after release 2021-04-21 13:19:48 +00:00
buildmaster
b6defb9438 Going back to snapshots 2021-04-21 13:19:48 +00:00
buildmaster
2103c0ad23 Update SNAPSHOT to 3.0.12.RELEASE 2021-04-21 13:16:49 +00:00
buildmaster
45805566f9 Bumping versions to 3.0.13.SNAPSHOT after release 2021-04-20 13:58:23 +00:00
buildmaster
ae2cb06364 Going back to snapshots 2021-04-20 13:58:22 +00:00
buildmaster
74d782461a Update SNAPSHOT to 3.0.12.RELEASE 2021-04-20 13:53:23 +00:00
Oleg Zhurakousky
6048d59517 Add test to vaidate defered output conversion 2021-04-16 09:40:01 +02:00
Oleg Zhurakousky
5adc174dc9 Make StreamBridge generate Message if user send just a POJO 2021-04-13 11:03:59 +02:00
Oleg Zhurakousky
b200d73b2d GH-2145 Add support for honoring SpEL on output payload in functions 
Typically output type conversion would happen in s-c-function which is a bit too early for cases when user uses SpEL on the output payload (e.g., Rabbit routing-key)
This defers this type conversion

Resolves #2145
 2021-04-07 15:37:15 +02:00
Oleg Zhurakousky
315028f461 SCF-GH-679 Add test to validate output conversion for composed functions 2021-04-07 11:55:21 +02:00
Oleg Zhurakousky
3999d4e6ac GH-2137 Remove references to EmitterProcessor 2021-04-06 15:54:20 +02:00
Oleg Zhurakousky
561742e7dd GH-2118 Wrap publishing ApplicationEvent in try/catch 
. . . to ensure that any exceptions resulting from custom implementation of ApplicationLstener does not harm the application
There will now be a WARN message and the stacj trace under DEBUG, but the application will continue to function.

Resolves #2118
 2021-03-22 18:30:37 +01:00
Oleg Zhurakousky
9b55bb838a GH-2132 Fix channel creation/registration logic 
SubscribableChannelBindingTargetFactory now capable of dealing with channels that may have been created outside of the normal process. In other words if channel exists as bean it will only cofigure it

Resolves #2132
 2021-03-22 18:15:14 +01:00
Oleg Zhurakousky
e0fdaa5b39 polishing backport comments 2021-03-19 16:16:46 +01:00
Oleg Zhurakousky
3c77e89de7 GH-2035 Add autodetect property to give user control over function autodetection 
Resolves #2035
 2021-03-19 16:10:23 +01:00
Oleg Zhurakousky
872da6cfec Fix checkstyle 2021-03-19 14:08:10 +01:00
Oleg Zhurakousky
f024ba2bb0 GH-1907 Decouple binding control from actuator 
This allows for easy programmatic control of binding lifecycle. The details are documented and as well as javadoced
Resolves #1907
 2021-03-19 14:01:51 +01:00
Oleg Zhurakousky
051c43c0e9 GH-2127 Wrap event publishing in try/catch issuing warning in case of error 
Resolves #2127
 2021-03-05 10:56:31 +01:00
Oleg Zhurakousky
98a856ac4e SCF-GH-661 Fix tests to validate KafkaNull conversion 2021-03-04 16:12:22 +01:00
Oleg Zhurakousky
f0178c148c GH-2106 Add bridge between destination channels and binding channel in TestChannelBinder 
Resolves #2106

polish
 2021-03-02 09:23:22 +01:00
Oleg Zhurakousky
ada0cd30e2 GH-2115 Fix test 2021-02-22 16:07:17 +01:00
Oleg Zhurakousky
5d9de8ad57 GH-2115 Ensure outbound interceptor is not used for functional approach 
Resolves #2115
 2021-02-22 15:32:54 +01:00
Oleg Zhurakousky
11acb6f5fb GH-2115 Add support for adding message converters from child context 
polish
 2021-02-22 15:32:37 +01:00
Soby Chacko
bd5c4c0427 Fix the snapshot versions: 3.0.12.BUILD-SNAPSHOT 2021-02-11 12:23:56 -05:00
buildmaster
cae4fa5838 Bumping versions to 3.0.12.SNAPSHOT after release 2021-02-11 06:10:49 +00:00
buildmaster
2685a42da5 Going back to snapshots 2021-02-11 06:10:48 +00:00
buildmaster
af544dd19a Update SNAPSHOT to 3.0.11.RELEASE 2021-02-11 06:08:44 +00:00
Oleg Zhurakousky
dd0061db6e GH-2112 fix test configuration 2021-02-10 08:38:01 +01:00
Oleg Zhurakousky
ee59bee415 GH-2112 Fix clear operation on TestBinder 
Resolves #2112
 2021-02-10 08:31:29 +01:00
Oleg Zhurakousky
ea4c87265e GH-2107 Add test to validate no NPE for function returning null 2021-02-08 18:18:55 +01:00
Oleg Zhurakousky
593959e033 GH-2103 - Added documentation to clarify threading expectation when using Supplier 2021-02-08 16:22:52 +01:00
Oleg Zhurakousky
a550d61af6 GH-2102 Remove legacy annotation binding documentation 
Resolves #2102
 2021-02-08 15:50:56 +01:00
Oleg Zhurakousky
4536b97269 GH-2058 Ensure uniqueness of error infrustructure in the event destination has the same name (multiple binders) 
Resolves #2058
 2021-01-27 09:14:33 +01:00
Oleg Zhurakousky
2b5b732604 GH-2042 Fix javadoc of InputDestination.send(..) 
Fixed explanatioin that the binder emultaes the real messaging system and that send accepts destination (not binding) name.

Resolves #2042
 2021-01-26 16:36:41 +01:00
Oleg Zhurakousky
d67efac42e GH-2073 Update documentation related to retries 2021-01-26 15:12:55 +01:00
Oleg Zhurakousky
8e072ba5d3 GH-2081 Add synchronization on channel resolution method in StreamBridge 
This should mitigate  race condition when StreamBridge is used in an async way
Resolves #2081
 2021-01-25 16:01:48 +01:00
Oleg Zhurakousky
dbdf3f5fb0 GH-2066 Ensure global error channel distributes messages in case of exception 
Resolves #2066
 2021-01-25 14:53:44 +01:00
Thomas Vitale
8ac35f723f Fix test binder usage examples 
The examples for testing Spring Cloud Stream in the presence of multiple
bindings contain some mistakes that make the tests fail.

Resolves #2070
 2021-01-13 17:36:40 +01:00
Oleg Zhurakousky
d998c199a3 GH-2078 Add support for honoring channel interceptors in StreamBridge 
Resolves #2078
 2021-01-13 17:32:53 +01:00
Oleg Zhurakousky
91c9709dcc GH-2077 Clarify StreamBridge.send semantics and add test to validate user properties are honored 
Resolves #2077
 2021-01-13 16:49:53 +01:00
Oleg Zhurakousky
3244fc5274 GH-2062 Add logic to log an error for reactive functions 
Resolves #2062
 2020-12-07 16:25:00 +01:00