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

1316 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Oleg Zhurakousky
cdeca51949 Update function to M3 2019-09-23 13:10:22 -04:00
Oleg Zhurakousky
4c94974261 Fix handling of native encoding/decoding for functions 2019-09-23 11:28:41 -04:00
Oleg Zhurakousky
19f843ed18 Changed '_' to '.' for convention used for function bean name delimiter 
Disconneced MessageChannelConfigurer from function processing

Upgraded to SCF M3 and Californium SR11
 2019-09-23 07:30:31 -04:00
Oleg Zhurakousky
c56b4d1ea9 Add initial support for functions wih multiple inputs/outputs as well as multiple functions 
- 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 #1746
Resolves #1745
Resolves #1314
 2019-09-18 13:22:40 +02:00
Oleg Zhurakousky
1723a40786 Added test for the previously fixed NPE 2019-09-16 10:14:43 +02:00
Marcin Grzejszczak
0f635c32f7 Added a NPE guard 2019-09-16 08:38:24 +02:00
Oleg Zhurakousky
5013103fcf GH-1794 Additional fixes and refactoring 2019-09-13 17:45:25 +02:00
Oleg Zhurakousky
808c7ead77 Put @AutoConfigureBefore back to FunctionConfiguration 2019-09-11 20:49:28 +02:00
Oleg Zhurakousky
d93f170f2e GH-1710 Added note on adding custom Validator 
Resolves #1710
 2019-09-11 16:19:37 +02:00
Oleg Zhurakousky
752cf6003c GH-1781 Fall back on JAXB dependencies provided by boot 
Resolves #1781
 2019-09-11 15:41:43 +02:00
Oleg Zhurakousky
bfbf8bfd31 GH-1802 Add ConsumerProperties usage to reactive function configuration 
Resolves #1802
 2019-09-11 15:29:21 +02:00
Oleg Zhurakousky
284d37fa2b GH-1799 Defer channel initialization until it is configured 
Resolves #1799
 2019-09-11 14:33:29 +02:00
Oleg Zhurakousky
043bf8e8c6 GH-1803 Propagate BindingProperties to FunctionConfiguration 
Resolves #1803
 2019-09-10 15:59:19 +02:00
Oleg Zhurakousky
f3b696f35e GH-1748 - Enhance routing function with SpEL and application properties 
Resolves #1748
 2019-09-10 14:40:32 +02:00
Oleg Zhurakousky
aa495ac4ae GH-1801 Fix NPE when factory method is null 
Fixed NPE for cases when factory method is null by attemptimng to discover factory method via source.MethodMetadata
Added tests

Resolves #1801
 2019-09-06 17:32:18 +02:00
Soby Chacko
e870c6505a Move Schema Registry out of Spring Cloud Stream 
Migrated to https://github.com/spring-cloud/spring-cloud-schema-registry

Resolves #1786
 2019-08-27 15:44:01 +02:00
Walliee
ea924ffb95 GH-1793 Fix BinderErrorChannel subscriber count 
Also, set component name on BinderErrorChannel object
so it doesn't show up as "unknown.channel.name"
Fix build

Resolves #1793
Resolves #1796
 2019-08-27 15:39:48 +02:00
Phillip Webb
db0fff9d32 Migrate from deprecated CompositeHealthIndicator 
Migrate `BindersHealthIndicatorAutoConfiguration` to use a
custom `CompositeHealthContributor` implementation rather
than the deprecated `CompositeHealthIndicator` class.
Resolves #1788
 2019-08-27 15:25:51 +02:00
Sabby Anandan
d98471d86d Add RocketMQ to the binders list 2019-08-27 15:12:57 +02:00
Oleg Zhurakousky
51c4991b0d GH-1794 Disabled function initialization for legacy cases 
Fix bypassing of the functional configuration for cases where legacy configuration elements are present (e.g., EnableBinding)
Resolves #1794
 2019-08-27 15:04:03 +02:00
Oleg Zhurakousky
1d56f143d0 GH-1797 Added support for PollableSupplier annotation 
Resolves #1797
 2019-08-27 13:10:03 +02:00
Oleg Zhurakousky
6bf1714374 add test for implicit consumer binding 2019-08-22 20:43:34 +02:00
jmaxwell
0ad15247f6 GH-1760 Deprecated findBySubjectAndVersionadded findBySubjectAndFormat 
Note also refactored and moved ServerController test class.
Increased coverage of ServerController to 100%.

polishing
 2019-08-19 18:50:24 -04:00
Soby Chacko
8dbea0719c Restore a test in ConfluentSchemaRegistryClientTests 
This test was removed in the previous PR commit 10b6d16ca3.
However, after making some slight adjustments, we can
still test this scenario.
 2019-08-19 18:29:26 -04:00
zhouzhou19950825
10b6d16ca3 Mismatch with server receive parameter format 
Making ConfluentSchemaRegistry registration process more consitent
with registering the Spring Cloud Stream ScheamRegistry server.
 2019-08-19 17:56:03 -04:00
Oleg Zhurakousky
433bea8f26 GH-1784 Fix support for Consumer-type handlers 
Resolves #1784
 2019-08-19 19:01:38 +02:00
Oleg Zhurakousky
99581a6158 Ser s-c-function back to 3.0.0.B-S 2019-08-13 12:22:43 +02:00
buildmaster
4e04277fe3 Going back to snapshots 2019-08-13 07:37:28 +00:00
buildmaster
07d895b202 Update SNAPSHOT to 3.0.0.M3 2019-08-13 07:36:18 +00:00
Oleg Zhurakousky
35bdb9164b Adjusted docs with recent s-c-build updates 
Upgraded to SCF 3.0.0.M2
 2019-08-13 09:04:08 +02:00
Oleg Zhurakousky
6c772bba08 GH-1742 Adjusted previous commit to new function infrustructure 
Resolves #1738
Resolves #1742
 2019-08-07 16:18:14 +02:00
Gary Russell
9fd674909a GH-1742 Support Batch Listeners in Core (Function) 
- 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.
 2019-08-07 15:58:59 +02:00
Oleg Zhurakousky
562a025cda GH-1762 Fixed binding lifecycle control to ensure it is based on bindingName 
Resolves #1762
 2019-08-07 11:10:02 +02:00
Oleg Zhurakousky
10682c6805 GH-1770 additional fixes on BindingService lifecycle 2019-08-07 10:46:33 +02:00
Oleg Zhurakousky
c35e362d10 GH-1772 remove temporary scope declaration 
Resolves #1772
 2019-08-07 09:20:30 +02:00
Oleg Zhurakousky
4ca3ed142d Retained schema registry modules for M3 release 2019-08-07 09:01:29 +02:00
Oleg Zhurakousky
69b93b22b9 GH-1767 disconnected and deprecatd @StreamMessageConverter 2019-08-06 19:15:49 +02:00
Oleg Zhurakousky
e8611cf9f7 GH-1776 Added support for beanName to DirectWithAttributesChannel 
Resolves #1776
 2019-08-02 20:29:47 +02:00
Oleg Zhurakousky
c6a805539e Refactored post processor into init bean for function-to-channel binding 2019-08-02 16:31:08 +02:00
Oleg Zhurakousky
35c0e1e9f0 GH-1775 Fix early initialisation of FunctionCatalog 
Resolves #1775
 2019-08-01 12:17:50 +02:00
Oleg Zhurakousky
eb7f774c4a GH-1739 Removed references to partitionSelectorClass and partitionKeyExtractorClass properties 
Resolves #1739
 2019-07-30 14:46:24 +02:00
Oleg Zhurakousky
e08f669a54 GH-1773 Added support for native spring.cloud.function.definition property 
Resolves #1773
 2019-07-30 14:41:27 +02:00
Oleg Zhurakousky
2ddd7973c4 GH-1770 Fixed BindingService unbinding lifecycle 
. . . to ensure the bindings are gracefully stopped before unibind is called

Resolves #1770
 2019-07-30 14:21:09 +02:00
Oleg Zhurakousky
1deec9d100 GH-1774 Improved error handling and visualizatioin on failed Bindings 
Resolves #1774
 2019-07-30 13:55:20 +02:00
Oleg Zhurakousky
c8a4b40de0 Fixed source and source-to-function functionality and tests 2019-07-30 13:54:30 +02:00
Oleg Zhurakousky
82530dd2cf polishing 2019-07-29 18:04:20 +02:00
Oleg Zhurakousky
34ea0144ec Removed cast to SmartInitializingSingleton for FunctionCatalog 2019-07-29 15:33:32 +02:00
Oleg Zhurakousky
a69f9b18d3 Made MessageHandlerMethodFactory bean temporarily prototype 2019-07-25 18:00:38 +02:00
Oleg Zhurakousky
e682fe0324 Disconnected reactive and schema-registry modules 
Resolves #1747
 2019-07-25 17:08:25 +02:00
Oleg Zhurakousky
945821e417 Temporarily ignored functional tests pending further review 
also, minor polishings
 2019-07-25 16:56:39 +02:00