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

1537 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
Mark Heckler
455ace12b6 Merge pull request #1993 from mkheck/master 
Fixed various small typos/ambiguities in docs
 2020-07-02 08:04:36 -05:00
Mark Heckler
f9f303c5f7 Fixed various small typos/ambiguities in docs 2020-06-30 10:51:17 -05:00
David Turanski
9d9dbb3ddd Provide no-op AcknowledgementCallback implementation if MessageHeader is not present and Add no-op callback to TestChannelBinder MessageSource. 
Resolves #1988
 2020-06-22 14:00:40 +02:00
Oleg Zhurakousky
55b9f541fb GH-1984 Fix applicationMetrics initialization 
Resolves #1984
 2020-06-22 11:09:19 +02:00
Oleg Zhurakousky
10fc8dea30 GH-1937 Remove error handling from reactive function bootstrap 
Resolves #1937
 2020-06-17 15:54:56 +02:00
Oleg Zhurakousky
9aa6eab026 GH-1936 Add operations to clear destinations queues to OutputDestination 
Resolves #1936
 2020-06-17 15:21:08 +02:00
Oleg Zhurakousky
9d5679ae1d GH-1966 Ensure dynamic destination property works for Messages wrapped as iterable/array types 
Resolves #1966
 2020-06-17 15:08:13 +02:00
Oleg Zhurakousky
9d37f48028 GH-1944 Add test to validate Supplier with collections of POJOs 
Resolves #1944
 2020-06-17 08:38:48 +02:00
Soby Chacko
ac833103a0 Adding junit-vintage dependency for junit4 tests 2020-06-15 17:24:47 -04:00
Oleg Zhurakousky
d38dddbf62 GH-1979 Fix SpelConverter registration for child context 
Basically the code was already fixed and working for Spel properties in multi-binder configuration. However the actual code was included in a wrong block and because of it was working conditionally based on an unrelated condition. This fixes it

Resolves #1979
 2020-06-11 17:07:14 +02:00
Oleg Zhurakousky
a89edd6121 GH-1973 Fix test binder to ensure it does not duplicate messages 
added test that reproduced and this validated the issue after it was fixed
as a side work some tests were migrated to junit 5

Resolves #1973
 2020-06-11 16:50:29 +02:00
Marcin Grzejszczak
a0ca3f57c1 Migrated to new documentation generation 2020-06-08 18:34:45 +02:00
Marcin Grzejszczak
7679d00b33 Changed packaging to jar 2020-06-08 17:12:41 +02:00
Oleg Zhurakousky
5867636d17 GH-1977 Add failure when consumer concurrency is > 1 for reactive consumers 
Providing that project reactor maintains it's own concurrency mechanisms, using stream's concurrency setting can lead to unexpected results including loss of messages.
This fixes it by disallowing concurrency setting when reactive consumers are used.

Resolves #1977
 2020-06-04 11:28:27 +02:00
Oleg Zhurakousky
a8f8a1659e GH-1978 Fix dynamic destination resolutino for reactive function 
Resolves #1978
 2020-06-04 09:50:59 +02:00
Oleg Zhurakousky
2337646a66 Fix imperative function|consumer composition 2020-06-03 17:09:11 +02:00
Oleg Zhurakousky
68e2c0d8ce Update s-c-function to 3.1.0-SNAPSHOT 2020-06-03 15:13:42 +02:00
Soby Chacko
198f5eeae9 Update version to 3.1.0-SNAPSHOT 2020-06-02 13:58:20 -04:00
fonio
73a5e362b4 Minor typo 
heck -> check
 2020-06-01 15:41:16 +02:00
Guilherme Torres Castro
0613f25800 Fix wrong function name in the scatter example 2020-06-01 15:40:54 +02:00
Oleg Zhurakousky
52dad60337 GH-1950 Add scst_targetDestination header 
The core framework does nothing with this header other then defining it. One can always use StreamBridge for general cases

Resolves #1950
 2020-05-28 14:22:18 +02:00
Oleg Zhurakousky
55ae6b087d GH-1967 Fixed support for converting collection types 
The main fix is actually in spring-cloud-function 417e54e0af
The changes here are mainly polishing and adjusting around function changes

Resolves #1967
 2020-05-21 11:18:28 +02:00
Oleg Zhurakousky
6ef016367c Remove setting required groups 2020-05-18 16:44:23 +02:00