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

1311 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
Oleg Zhurakousky
9a98e5814d Added initial refactoring to account for new FunctionCatalog implementation 2019-07-25 15:35:07 +02:00
Walliee
28894afed7 Fix pollable consumer auto-startup 
resolves #1758
 2019-07-08 17:21:32 +02:00
Oleg Zhurakousky
77f6d96bc3 GH-1729 Added support for DLQ to functional programming model 
- Change FunctionInvoker.onError() to send to binding error channel instead of global one
- Binders contain relevant changes as well

Resolves #1729
Resolves #1730
 2019-07-08 17:08:50 +02:00
Oleg Zhurakousky
4c7a9b098a Removed BindableProvider in favor of BindingProvider marker annotation 
Simplified the code by simply requiring implementors of the binders to annotate their configuration with BindingProvider to signal its intention to handle the actual binding

Resoloves #1753
 2019-07-08 16:29:08 +02:00
Soby Chacko
8af53028f5 Bypassing target type binding 
When functional model is used and no EnableBinding is provided, this PR allows
core Spring Cloud Stream to skip any target type binding if the downstream
binder is capable of such binding on the target type. In that case, the target
binders provide their own BindableTargetProxyFactory.

Introduce additional properties in StreamFunction properties to allow overriding the
input/output bindings.

Resolves #1751
 2019-07-08 16:29:08 +02:00