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

1560 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
hemeda3
cff4a3ac9b Minor typo 
input` vs input
 2020-11-25 09:18:06 +01:00
Oleg Zhurakousky
f80f85e1a0 GH-2054 Add test to validate regression with reactive functions 
Resolves #2054
 2020-11-25 09:15:56 +01:00
igor
b48485e7fa Update spring-cloud-stream.adoc 2020-11-23 20:36:17 +01:00
Soby Chacko
02c642ff99 Add missing timeUnit in DefaultPollerProperties 
Fixing docs

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2052
Resolves #2053
 2020-11-20 09:36:57 +01:00
Сергей Цыпанов
8cf5e62820 Don't check bridge and synthetic methods in postProcessAfterInitialization() 
Resolves #2046
 2020-11-20 09:29:59 +01:00
Soby Chacko
442c72b37c Muti binder customization (#2051) 
* Muti binder customization

Enable applications with multi binders to provide customizations for
the binders. This is accomplished by providing a new API called
BinderCustomizer. When an implementation is found for this interface,
the customizations are applied against the binders before providing access to them.

Tests and docs.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/1541

* Addressing PR review comments

* Addressing PR review
 2020-11-18 16:32:05 -05:00
buildmaster
d574ee15be Going back to snapshots 2020-11-17 15:13:05 +00:00
buildmaster
a1a00a845c Update SNAPSHOT to 3.1.0-M4 2020-11-17 15:10:56 +00:00
Oleg Zhurakousky
d9bb929b04 Update versioins for the release 2020-11-17 15:32:39 +01:00
Oleg Zhurakousky
c1c8758a47 Fix logic around filtering functions 2020-11-06 11:27:18 +01:00
Oleg Zhurakousky
ea6a90c3fc Fix handling of sending array type outputs 2020-10-30 10:33:56 +01:00
Oleg Zhurakousky
a8db175568 Add additional tests to validate edge scenarious 2020-10-27 15:04:00 +01:00
Oleg Zhurakousky
550931c79b SCF-GH-599 Add test to validate the header propagation behavior 2020-10-24 08:26:01 +02:00
Oleg Zhurakousky
5b04295570 Consolidate support for native encoding/decoding 2020-10-23 17:24:20 +02:00
Oleg Zhurakousky
bf9aee8b74 Add function filtering mechanism 
This is to accommodate Kafka streams binder, since it does not rely on binding mechanism provided by s-c-stream core
 2020-10-22 10:10:02 +02:00
Oleg Zhurakousky
bb1b7fd81f GH-2021 Add bridge to SI created error channel if not PublisheSubscribe 
When @ServiceActivator is used to configure error handler to a binding specific error channel, if such channel is not created manually as pubsub, SI will create it as DirctChannel. This fix ensures that in such case a new PubSub channel is created and bridged to an SI created channel to ensure there can always be multiple subscribers to error channel

Resolves #2021
 2020-10-21 11:46:18 +02:00
Oleg Zhurakousky
d23cb9b1fb GH-2027 polishing 2020-10-21 08:25:46 +02:00
Oleg Zhurakousky
a7d2e14e80 GH-2027 Ensure imperative Supplier behavior during composition 
This fix ensures that whenever imperative Supplier is composed with reactive function its poling behavior and expectations are preserved

Resolves #2027
 2020-10-21 07:56:10 +02:00
Oleg Zhurakousky
0c0aaec148 Cleanup and refactor to accomodate changes in SimpleFunctionRegistry of SCF" 2020-10-20 15:41:50 +02:00
Oleg Zhurakousky
14f1d285e4 Change function to snapshot 2020-10-14 16:01:49 +02:00
David Turanski
c2ae2dbba8 Change exception to warning message and ignore @PollableBean for imperative functions 2020-10-07 10:56:41 -04:00
Oleg Zhurakousky
e3faae2091 GH-2026 Formally deprecate annotation-based programming model 
Deprecate all relevant annotation such as EnableBinding and StreamListener
Remove all mentions of them from documentation

Resolves #2026
 2020-10-06 15:34:11 +02:00
buildmaster
40971567d5 Going back to snapshots 2020-10-02 10:07:50 +00:00
buildmaster
46ba453cd1 Update SNAPSHOT to 3.1.0-M3 2020-10-02 10:06:11 +00:00
HwangJinSeong
a188d5be1c Fix typo in Common Binding Properties section 2020-10-02 11:46:46 +02:00
David Turanski
2bc8404f22 Throw exception on invalid function definition 
Resolves #2022
 2020-09-28 13:16:30 +02:00
buildmaster
a17ef6d09d Bumping versions 2020-09-24 15:41:28 +00:00
Oleg Zhurakousky
05416186ee Update reactor and function version 2020-09-24 17:28:30 +02:00
Oleg Zhurakousky
645cf5ec0c Update docs module artifact id 2020-09-24 17:11:39 +02:00
Oleg Zhurakousky
86c6a7b421 Fix docs links 2020-09-24 16:15:49 +02:00
Oleg Zhurakousky
ac98fb1206 GH-1981 Fix delayed subscription for reactive consumer 
Resolves #1981
 2020-09-22 21:42:00 +02:00
Oleg Zhurakousky
9a906e7369 GH-1956 Add support for PollableSource in functional programing model 
This feature effectively provides identical path to create PollableSource as it was in annotation-based programming model.
However, unlike creating and  providing binding intreface all that is required from user is 'spring.cloud.stream.pollable-source' property

Resolves #1956
 2020-09-22 20:32:14 +02:00
Oleg Zhurakousky
66eaef460d Fix support for binding names for function definitions with comas 2020-09-22 16:42:16 +02:00
Oleg Zhurakousky
3364771da5 GH-2007 Ensure StreamBridge does not attempt to create Message from Message 
Resolves #2007
 2020-09-22 15:05:45 +02:00
Oleg Zhurakousky
29fb69a2cd GH-2014 Add support for NewDestinationBindingCallback back to StreamBridge 
Resolves #2014
 2020-09-22 13:58:52 +02:00
guycall
6fed9dc91e Fix typo in Event Routing section 2020-09-15 07:48:06 -07:00
Oleg Zhurakousky
ef51351108 Add RSocket snapshot repo 2020-08-06 19:23:13 +02:00
Oleg Zhurakousky
75dbcb8b7b Update reactor to the latest snapshot 2020-08-06 16:16:59 +02:00
Oleg Zhurakousky
5dc29af8ae Add test to validate GH-573 from s-c-function 2020-08-04 19:57:39 +02:00
Oleg Zhurakousky
f801313a66 GH-2011 Remove log override from test binder 
Resolves #2011
 2020-08-04 16:40:27 +02:00
Oleg Zhurakousky
43b31c927a Add KafkaNull test 2020-07-24 14:55:51 +02:00
Oleg Zhurakousky
95dda5c112 Fix StreamBridge to honor destination that may already be in AC 2020-07-24 10:21:32 +02:00
buildmaster
ade88ad518 Going back to snapshots 2020-07-20 15:05:12 +00:00
buildmaster
bb53299a10 Update SNAPSHOT to 3.1.0-M2 2020-07-20 15:03:41 +00:00
Oleg Zhurakousky
0048b8aef4 GH-2006 Add test for KafkaNull 
Resolves #2006
 2020-07-20 08:19:04 +02:00
Oleg Zhurakousky
1e2aec68ab GH-2006 Add special handling of KafkaNull to SmartMessageMethodArgumentResolver 2020-07-19 18:37:50 +02:00
Ahian Zhang
632c57bcf3 Update preface.adoc 
fix the picture does not show
 2020-07-15 10:06:05 +02:00
Jay Bryant
6297fb2047 Wording changes 
Replacing some terms
 2020-07-15 10:05:43 +02:00
Oleg Zhurakousky
839e0267f7 Fix Spring Integration DSL calls 
upgrade reactor version
 2020-07-15 10:01:20 +02:00
Soby Chacko
725d60bdd4 GH-1998: StreamBridge API and conversion logic. 
When native encoding is enabled, the StreamBridge API still tries
to convert using the default converter causing runtime exceptions.

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/1998
 2020-07-02 12:05:11 -04:00