Commit Graph

558 Commits

Author SHA1 Message Date
Oleg Zhurakousky
3cb9dde679 GH-932 Fix registration of AWSTypesMessageConverter for functional spring applications
Resolves #932
2022-11-10 12:13:57 +01:00
Mathias Nicolajsen Kjærgaard
20e0e4eb73 Make CloudEventsFunctionExtensionConfiguration public to allow manual import
It is not possible to load CloudEventsFunctionExtensionConfiguration using @ImportAutoConfiguration() if it is package private.
2022-11-03 20:22:10 -04:00
Neokeld
7e53848e1a functionRegistration cant be null
Resolves #950
2022-11-02 10:07:56 +01:00
Oleg Zhurakousky
53cc7c8f93 GH-949 Clean up output conversion logic
Resolves #949
2022-11-01 12:58:12 +01:00
Oleg Zhurakousky
e8b15a3c95 GH-947 Ensure FunctionAroundWrapper is not registered
In 4.x it will not since it is not a function, but here we needed a filtering logic during the default lookup

Resolves #947
2022-10-31 15:54:57 +01:00
Neokeld
9461d20432 mcList is always not empty 2022-10-31 10:51:48 +01:00
Oleg Zhurakousky
931dfa22a8 Clean up applicability of FunctionAroundWraapper 2022-10-31 09:18:08 +01:00
Oleg Zhurakousky
62ffbc12b6 SLEUTH-2051 Ensure that sleuth is not applied when reactive and non-message inputs are used 2022-10-27 15:16:45 +02:00
Neokeld
47f3964435 Simple refactor: function is always null, see l121
Resolves #934
2022-10-18 15:05:50 +02:00
Soby Chacko
5a0d184c5c Conditional loading of AVRO message converter
Introducing a property to disable loading the AVRO message converter.
When spring.cloud.stream.avro.enabled is set to false, the converter
is not loaded. By default, it is enabled.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/854
2022-09-21 17:17:49 -04:00
Oleg Zhurakousky
db892f6b67 Polishing previous commit 2022-09-20 18:35:27 +02:00
Oleg Zhurakousky
17cd163f29 GH-925 Fix regression with Kotlin @Component regstration
Resolves #925
2022-09-20 18:10:46 +02:00
Oleg Zhurakousky
608d37962b GH-924 Fix regression with structured CE cnversion into Message
Resolves #924
2022-09-08 15:47:50 +02:00
Oleg Zhurakousky
0af24dfd6b GH-919 Fix regression that was modifying result message
Resolves #919
2022-08-24 16:19:44 +02:00
Oleg Zhurakousky
10715d67dc GH-918 Fix Kotlin function invocation
For some reason it contained code that was doing some special checking for array and was returning null.
Resolves #918
2022-08-17 18:42:38 +02:00
Oleg Zhurakousky
f22561ed47 GH-917 Fix regression with sanitizing headers
Resolves #917
2022-08-16 16:43:38 +02:00
Oleg Zhurakousky
392a1f6103 GH-915 Make Kotlin initialization 'lazy'
This way just like with any other function, Kotlin initialization, type discovery etc will be performed on function lookup
This will also ensure that order of various post processors doesn't get in the way.

Resolves #915
2022-08-11 16:59:09 +02:00
Oleg Zhurakousky
4d18d3b7d6 GH-909 Fix spelling of the method
Resolves #909
2022-08-08 15:32:57 +02:00
Oleg Zhurakousky
e0f156b407 GH-905 Relax handling of incompatible BiFunctions
Resolves #905
2022-08-03 18:02:38 +02:00
Oleg Zhurakousky
342c2bb533 GH-901 add more logging around failed conversion of input messages
Resolves #901
2022-07-26 17:36:12 +02:00
Maciej Walkowiak
14266d14d8 Fix typo.
Fix typo.
2022-07-26 11:50:04 +02:00
Oleg Zhurakousky
02e9adf0c6 Relax logging in SimpleFunctionRegistry 2022-07-25 15:46:13 +02:00
Oleg Zhurakousky
7cd0266628 Remove reflection usage to accomodate AOT 2022-07-25 15:14:45 +02:00
Oleg Zhurakousky
7d262d894f GH-895 Remove reflection usage form CloudEventMessageUtils 2022-07-13 13:53:29 +02:00
Oleg Zhurakousky
10244a044b Fix function eligibility filtering 2022-06-17 15:49:44 +02:00
Oleg Zhurakousky
d5666792d6 GH-884 Add initial support for BiConsumer 2022-06-15 16:17:19 +02:00
Oleg Zhurakousky
9bd83402e4 GH-884 Add initial support for BiFunction
Resolves #884
2022-06-14 09:08:31 +02:00
Oleg Zhurakousky
37a81f3a02 GH-883 Add support for filtering out ineligible functions
Resolves #883
2022-06-13 15:47:29 +02:00
Oleg Zhurakousky
24abaa7f87 Add author 2022-06-09 15:03:44 +02:00
Oleg Zhurakousky
3b693304dd checkstyle 2022-06-09 14:51:45 +02:00
Oleg Zhurakousky
eeafa09b68 SCST-GH-2355 Add support for batch processing of collections with different types
Specifically KafkaNull. But this commit effectively paves a path for any type
2022-06-09 14:51:35 +02:00
Oleg Zhurakousky
808fb28f5c Initial commit of KafkaNull changes to SmartCompositeMessageConverter 2022-06-09 14:51:24 +02:00
Oleg Zhurakousky
83901cf16d KafkaNull batch attempt 2022-06-09 14:51:14 +02:00
Oleg Zhurakousky
630dcf2267 Back-port of https://github.com/spring-cloud/spring-cloud-function/pull/871 2022-06-07 16:51:51 +02:00
Oleg Zhurakousky
6ecb261487 GH-873 Fix JsonNode conversion
Resolves #873
2022-05-30 14:38:34 +02:00
Oleg Zhurakousky
0576b6c6ce GH-878 Fix concurrency issue during registration and lookup of functions
Resolves #878
2022-05-30 12:10:58 +02:00
Oleg Zhurakousky
080be7f40c GH-739 Add DEBUG log statement for when type conversion fails
Resolves #739
2022-05-04 15:09:57 +02:00
Oleg Zhurakousky
63ad1dead6 GH-791 Add support for propagating input headers
Resolves #791
2022-05-04 13:20:01 +02:00
Oleg Zhurakousky
684942e680 GH-856 Fix logic in determining Cloud Event prefix
Resolves #856
2022-04-26 08:39:48 +02:00
REMY David
a2b87854d8 Change OffsetTime to OffsetDateTime in CloudEventMessageUtils
Resolves #855
2022-04-21 11:02:38 +02:00
Oleg Zhurakousky
17dda179bc Fix compilation error in test 2022-03-25 14:44:04 +01:00
Oleg Zhurakousky
281c5baa61 Fix conversion logic in SmartCompositeMessageConverter 2022-03-25 14:25:05 +01:00
Oleg Zhurakousky
03db9baee6 GH-828 Add support for configuring additional routers
Resolves #828
2022-03-24 18:27:28 +01:00
Oleg Zhurakousky
4eb4f741a5 GH-830 Fix conversioin exception for custom converters
Resolves #830
2022-03-23 17:17:24 +01:00
Oleg Zhurakousky
986c0a09d8 GH-832 Change OffsetTime to OffsetDateTime in CloudEventMessageBuilder
Resolves #832
2022-03-23 13:18:04 +01:00
Oleg Zhurakousky
e1f2820fd1 Fix typo 2022-03-22 16:39:18 +01:00
Oleg Zhurakousky
ca9e816a8f Polishing 2022-03-22 15:56:26 +01:00
Oleg Zhurakousky
d15d42894a Perf improvement 2022-03-22 15:45:13 +01:00
Oleg Zhurakousky
61b7023610 Performance improvements related to SCST-2303 2022-03-22 13:54:26 +01:00
Oleg Zhurakousky
1f54dbf036 Clean up code 2022-03-08 14:38:34 +01:00