- 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
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`
- Currently there is no multi-out support for Supplier and I am not really sure what the use case would be so holding off.
- The logic in FunctionConfiguration effectively split in bootstrapping simple functions (e.g., Function<String, String>) vs. multi-in/out (e.g., Function<Tuple2<Flux<String>, Flux<String>>, Flux<String>>). This is temporary given that multi-in/out is still considered WIP. Once it becomes stable we can merge the two two for consistency.
- Added multiple input/output support for TestBinder
- Updated documentation
Resolves#1746Resolves#1745Resolves#1314
- Support `batchMode` in function properties so, for binders that support batch listeners, a message
payload of `List<byte[]>` can be properly converted.
- In batch mode, handle
`public Function<List<Person>, Person> func()`
`public Function<List<List<Person>>, Person> func()`
`Function<Message<List<Person>>, Person> func()`
- Also use `ParameterizedType` as a conversion hint for `public Function<List<Person>, Person> func()`
when not in batch mode (json: `[{\"name\":\"bob\"},{\"name\":\"jill\"}]`). Previously, just the'
class was used without generic type information.
Move batchMode to ConsumerProperties.
Fix imports
Remove duplicate test from if test for message conversion.
