138 Commits

Author SHA1 Message Date
Oleg Zhurakousky
3999d4e6ac GH-2137 Remove references to EmitterProcessor 2021-04-06 15:54:20 +02: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
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
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
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
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
igor
6f867ad87f Update spring-cloud-stream.adoc 2020-12-07 14:39:28 +01:00
Oleg Zhurakousky
124638e079 polish 2020-11-23 15:29:48 +01:00
Soby Chacko
02f42ab79c Add missing timeUnit in DefaultPollerProperties
Fixing docs

Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2052
Resolves #2053
2020-11-20 17:38:52 +01:00
Oleg Zhurakousky
7643e1575d Fix doc links 2020-10-06 14:43:39 +02:00
fonio
284b54873d Minor typo
heck -> check
2020-06-01 15:42:59 +02:00
Guilherme Torres Castro
1325d425ff Fix wrong function name in the scatter example 2020-06-01 15:42:49 +02:00
Guilherme Torres Castro
fcc1b6fe2b Remove duplicate property in documentation 2020-05-18 15:26:08 +02:00
Mayur Raiyani
202937a9e9 Update spring-cloud-stream.adoc 2020-05-18 15:26:02 +02:00
Oleg Zhurakousky
52551b50a5 GH-1938 Improve documentation on foreign event-driven sources
Resolves #1938
2020-04-08 17:08:24 +02:00
Oleg Zhurakousky
09fc8b146c GH-1924 Add support for dynamic destinations to StramBridge
Resolves #1924
2020-03-24 17:12:48 +01:00
Oleg Zhurakousky
9239354f25 Bump s-c-function to 3.0.4.B-S
Change docs reference of StreamBridgeUtils to StreamBridge
2020-03-09 20:12:40 +01:00
Oleg Zhurakousky
9bc1c3b9da Put back producer property description 2020-03-02 17:52:17 +01:00
Oleg Zhurakousky
67461495f9 GH-1912 Added support for non-reactive-source messaging bridge
Currently the use of reactive EmitterProcessor is the only way to connect foreign sources such as HTTP with spring-cloud-stream
The newly added StreamBridgeUtils class provides a simpler mechanism to brideg non-stream application with stream application without requiring reactor API while also honoring the same type conversion and partitioning contract used by functions

Added docs

Resolves #1912

Address PR comments

Resolves #1918
2020-02-27 18:15:02 +01:00
Oleg Zhurakousky
51f6187e39 GH-1893 Added partition support for Supplier
- Expended functional support for SpEL-based partitioning of outgoing messages that was added cce66f338a to Supplier.
- Added tests

- polished docs

Resolves #1893
2020-02-10 16:42:56 +01:00
Oleg Zhurakousky
968d3581df Updated initializr image 2020-02-06 14:48:50 +01:00
Oleg Zhurakousky
2dc7e89345 GH-1902 Added support for contentType value as byte[]
changed stream overview image to showcase functional programming model

Resolves #1902
2020-02-06 14:31:19 +01:00
Oleg Zhurakousky
93a489ac9a Updated testing section with destination naming
Related to #1894
2020-01-29 11:03:48 +01:00
Oleg Zhurakousky
a94e533a50 GH-1894 Added support for named destination in test binder
Deprecated indexed operations
Modified several tests to use new operators

Resolves #1894
2020-01-24 19:16:21 +01:00
Oleg Zhurakousky
92379f60c7 GH-1891 Updated the doc by adding a note on Consumer 2020-01-24 13:21:48 +01:00
Oleg Zhurakousky
9ce5e57080 Clean up and refactoring
- Upgraded to functions 3.0.2.BS
- Fixed Supplier sample in documentation (see https://stackoverflow.com/questions/59744352/messagedeliveryexception-in-case-of-using-function-and-supplier-in-one-spring-cl)
- Consolidated and simplified logic around bootstrapping multiple argument and single arguments functions
- Added test for useNativeEncoding
2020-01-15 07:05:12 +01:00
Oleg Zhurakousky
65940f8904 Removing white spaces
Resolves #1875
2020-01-08 16:50:46 +01:00
Domenico Sibilio
05fa603639 Embed documentation on how to implement custom binders 2020-01-08 16:45:50 +01:00
Kamil Szymanski
0ef225577a Fix typos 2019-12-20 15:39:50 +01:00
Oleg Zhurakousky
435c3f8af9 GH-1871 Added Artem's post to Spring Integration section
Resolves #1871
2019-12-18 15:17:44 +01:00
Oleg Zhurakousky
2091a005c5 GH-1867 Updated documentation with web source
Resolves #1867
2019-12-18 14:25:47 +01:00
Oleg Zhurakousky
528eaf041a GH-1868 removed where possible references to a word 'channel' from documentation
Resolves #1868
2019-12-18 09:14:39 +01:00
Oleg Zhurakousky
92ae704a2f GH-864 added link to community post on custom binder implementation
Resolves #864
2019-12-18 07:53:04 +01:00
Oleg Zhurakousky
c6bb38dcd6 Updated Testing section of user guide 2019-12-17 06:29:20 +01:00
Oleg Zhurakousky
ea9ffcdd78 GH-1868 Initial work on removing references to 'channel' word 2019-12-11 18:36:52 +01:00
Oleg Zhurakousky
b06d6f9a0c GH-1866 Updated documentation to clear up binding names
Resolves #1866
2019-12-09 19:50:12 +01:00
Oleg Zhurakousky
355cb0c4f1 Fixed image links
removed flatten plugin
2019-12-06 10:16:22 +01:00
Oleg Zhurakousky
e2467696b0 GH-1854 Fixed typo in the doc
Resolves #1854
2019-12-02 14:59:42 +01: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
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
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
2310bc698e GH-1838 Deprecated BinderAwareChannelResolver
Resolves #1838
2019-10-31 20:19:59 +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
44f114e4e7 Polishing docs 2019-10-28 17:37:40 +01:00