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

1382 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
buildmaster
253f3d6547 Bumping versions to 3.0.1.BUILD-SNAPSHOT after release 2019-11-22 14:19:03 +00:00
buildmaster
8e5490d792 Going back to snapshots 2019-11-22 14:19:03 +00:00
buildmaster
814d008da5 Update SNAPSHOT to 3.0.0.RELEASE 2019-11-22 14:17:49 +00:00
Oleg Zhurakousky
6fdfa22c5e GH-1846 Update documentation on 'splittable' attribute of PollableBean 
Resolves #1846
 2019-11-22 14:38:58 +01:00
Oleg Zhurakousky
16af183df2 GH-1845 Fix ClassCast Exception when retrieving bean definition 
During search for PollableBean we assumed that the underlying supplier definition is RootBeanDefinition which is not always the case

Resolves #1845
 2019-11-22 13:05:07 +01:00
Oleg Zhurakousky
8a1c4acb1c GH-1851 ensured proper ordering of custom message converters 
Resolves #1851
 2019-11-22 12:55:32 +01:00
Oleg Zhurakousky
9354dde5fc Remove re-queue on error section from the docs 
polish
 2019-11-20 17:57:33 +01:00
Oleg Zhurakousky
fb088215f3 GH-1818 Improve error handling with reactive functions 
- Switched to using SI fix for channel-to-publisher adaptation
- Fixed retries for reactive functions
- Fixed DLQ handling for reactive functions
- Updated documentation

Resolves #1818
 2019-11-19 09:36:41 +01:00
Oleg Zhurakousky
596e6bea39 Improve function binding documentation 
- Added more details around descriptive binding name
- Added more details around functional composition and explicit binding names
 2019-11-18 10:49:30 +01:00
Oleg Zhurakousky
9db5f64a70 Initial fix for binding name of composed functions 2019-11-12 19:01:08 +01:00
Gary Russell
0d9982fddb GH-1841: Move invocation to before aPS() 2019-11-11 11:19:48 -05:00
Gary Russell
22872c3232 GH-1841: Add ConsumerEndpointCustomizer 
Fixes https://github.com/spring-cloud/spring-cloud-stream/issues/1841
 2019-11-11 10:56:09 -05:00
buildmaster
8494138029 Going back to snapshots 2019-11-08 16:16:19 +00:00
buildmaster
f075763960 Update SNAPSHOT to 3.0.0.RC2 2019-11-08 16:14:17 +00:00
Oleg Zhurakousky
1ad96c364f Ignored test due to boot change 
Need tyo revisit it before release. Outside of test functionality is verified
 2019-11-08 17:10:27 +01:00
Oleg Zhurakousky
c49c7b5e48 Added flatten plug-in 2019-11-08 16:34:00 +01:00
Gary Russell
602c4c4112 Fix typo 2019-11-07 09:27:37 -05:00
Michailidis Michael
8838d9227e Support consumption from multiple non-native part. 
Currently, non-native partitioning (e.g. RabbitMQ) require
an instance per partition.
Add support to allow one instance to consume from multiple
partitions.

Changed instanceIndex from single valued to List

Added a new property to support index list to spawn multiple consumers

added test for the index list usage

added author to the changed files. Fixes-gh-1232

Using object utils to check if a list is empty

Only look at indexes when partitioned

Add docs for `instanceIndexList`
 2019-11-06 15:50:37 -05:00
Oleg Zhurakousky
fa40b7f476 GH-1835 Changed channel-to-publisher adapter logic to use EmitterProcessor 
This effectively transforms Publisher to back-pressure honoring publisher

polishing
 2019-11-01 15:58:29 +01:00
Oleg Zhurakousky
a2595a26e3 GH-1835 Fixed channel-to-publisher adapter 
- Needed to copy one from SI to address the issue but the actual fix should go into SI

Resolves #1835
 2019-11-01 12:44:16 +01:00
Oleg Zhurakousky
2310bc698e GH-1838 Deprecated BinderAwareChannelResolver 
Resolves #1838
 2019-10-31 20:19:59 +01:00
Oleg Zhurakousky
e2a41e7871 GH-1837 Fix dynamic destination resolution for Supplier 
Resolves #1837
 2019-10-31 20:05:35 +01:00
Oleg Zhurakousky
b8de26b4f7 Polishing routing documentation 2019-10-31 14:55:51 +01:00
Oleg Zhurakousky
6c6d41c8ca Updated docs with routing documentation 2019-10-31 11:45:22 +01:00
Oleg Zhurakousky
a054f047f3 GH-1834 Fix reactive consumer 
Added null check for reactive wirong in FunctionConfiguration

Resolves #1834
 2019-10-28 17:45:28 +01:00
Oleg Zhurakousky
44f114e4e7 Polishing docs 2019-10-28 17:37:40 +01:00
Oleg Zhurakousky
0a59a60a7f Fix RoutingFunction initialization based on routing-expression 2019-10-28 16:25:31 +01:00
Oleg Zhurakousky
9ec31d8fd7 Polishing docs 2019-10-28 16:01:54 +01:00
Oleg Zhurakousky
2345be9905 Updated error handling section 2019-10-28 14:31:50 +01:00
buildmaster
f26c7661f4 Going back to snapshots 2019-10-24 15:45:03 +00:00
buildmaster
65ca0d99df Update SNAPSHOT to 3.0.0.RC1 2019-10-24 15:44:07 +00:00
buildmaster
32c0721e42 Bumping versions 2019-10-24 12:21:05 +00:00
Oleg Zhurakousky
864e7fedf1 GH-1829 Add 'multiplex' consumer property to the doc 
Fix javadoc by removing the note about users not being expected to set this property

Resolves #1829
 2019-10-24 12:50:23 +02:00
Oleg Zhurakousky
361daefb17 GH-1812 Add support for property-based dynamic destination resolution 
Added initial support for property-based dynemic destination resolution
Added initial documentation

Resolves #1812
 2019-10-24 12:44:21 +02:00
Oleg Zhurakousky
cbe3868c5b Remove BindingProvider 2019-10-24 08:29:05 +02:00
Oleg Zhurakousky
44b09b13e4 Removed dependency on BindingProvider 2019-10-23 21:54:15 +02:00
Artem Bilan
a516f9382d Add ProducerMessageHandlerCustomizer support 
Related to https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/issues/107

In some cases there is not enough configuration properties to setup
a producing `MessageHandler` in the binder.
Or we just can't do that via properties because some real object is
required for particular MH option.
For example in the AWS Kinesis Binder end-user would like to provide
a custom `AsyncHandler` which definitely cannot be expressed via properties

* Introduce a `ProducerMessageHandlerCustomizer` similar to existing
`MessageSourceCustomizer` and `ListenerContainerCustomizer`
* Add an `AbstractMessageChannelBinder.setProducerMessageHandlerCustomizer()`
to avoid breaking changes with an additional constructor arg
* Use a provided `handlerCustomizer` in the `customizeProducerMessageHandler()`
called from the `doBindProducer()` on the current `MH` before its
`afterPropertiesSet()`
* It is a target binder configuration responsibility to inject a
`ProducerMessageHandlerCustomizer` into the binder bean

Resolves #1828
 2019-10-23 16:43:39 +02:00
Oleg Zhurakousky
551a6a4dd0 Simplified previous commit 2019-10-23 16:32:09 +02:00
Soby Chacko
72e96a3b2e Provide MessageConverterConfigurer conditionally 
Check for conditions when MessageConverterConfigurer must be instantiated
even in the presence of `spring.cloud.stream.function.definition`.
 2019-10-22 13:23:01 -04:00
Soby Chacko
713c252576 Fix issues with binders and BindingProvider 
When multiple binders are present with at least one of them is marked with BindingProvider,
it skips scanning functions for regular message channel based binders.

Resolves #1820
 2019-10-17 20:34:13 +02:00
Oleg Zhurakousky
ad64df05a1 GH-1823 Make FunctionConfiguration conditional 
Resolves #1823
 2019-10-17 20:33:36 +02:00
Oleg Zhurakousky
8b7e76c3b0 Polishing FunctionConfiguration and test 2019-10-16 15:51:36 +02:00
Oleg Zhurakousky
5a3aa35f91 Update documentation with binding name changes 2019-10-16 14:42:20 +02:00
Oleg Zhurakousky
dc7f1734de Change to PollableBean to accomodate s-c-function change 2019-10-16 14:08:52 +02:00
Oleg Zhurakousky
4ede865c90 Fix StreamFunctionProperties bindings property usage 
fix usage of PollableSupplier and update documentation
 2019-10-08 06:09:03 -05:00
Dave Syer
e033b17eef Clarify units of measurement of fixedDelay 2019-10-04 15:10:28 +01:00
Oleg Zhurakousky
8858b7d417 Polishing testing section in docs 2019-10-03 16:41:37 -04:00
Oleg Zhurakousky
a84cd07dfc Simplify configuration of TestBinder 2019-10-03 14:04:51 -04:00
Oleg Zhurakousky
1fb479ff6d GH-1397 Ensure dynamic destinations properly configured 
Resolves #1397
 2019-09-30 19:18:22 -04:00
Oleg Zhurakousky
7f52ffc184 Remove references to original content type 2019-09-30 14:57:35 -04:00