Commit Graph

609 Commits

Author SHA1 Message Date
Oleg Zhurakousky
6b9b9995ab Revert "GH-986 Fix regression to NOT attempt output conversion of Message<byte[]>"
This reverts commit b1237c2ab2.
2023-01-19 17:19:03 +01:00
Oleg Zhurakousky
b1237c2ab2 GH-986 Fix regression to NOT attempt output conversion of Message<byte[]>
Resolves #986
2023-01-17 14:15:10 +01:00
Oleg Zhurakousky
4dcf0be7b3 GH-985 Ensure PassThruFunction is not pre/post processed
Resolves #985
2023-01-11 16:35:37 +01:00
Lars Bilger
2be70c5829 fix: resolve function type from non-parameterized Kotlin class that implements a function type
Resolves #925
Resolves #940
Resolves #956
Resolves #964

Resolves #982
2023-01-09 16:26:17 +01:00
Soby Chacko
8a5eafa58f KafkaNull check improvements
Related to f5e606dc55

Resolves #983
2023-01-09 16:04:17 +01:00
Oleg Zhurakousky
49ec082746 Enhance warning message when default function can not be determined 2023-01-09 15:54:55 +01:00
Soby Chacko
f5e606dc55 KafkaNull related improvements
When using KafkaNull on the outbound (StreamBridge for ex),
there is a bug that prevents it from working properly.

See https://github.com/spring-cloud/spring-cloud-stream/issues/2614 for more details.

Resolves #981
2023-01-06 09:52:14 +01:00
Oleg Zhurakousky
d4e6d7f05b GH-964, GH-959 Fix Kotlin type discovery
Resolves #964
Resolves #959
2022-12-15 12:54:51 +01:00
Neokeld
a8f25efceb Corrects some branching for readability
Resolves #960
2022-11-29 11:50:12 -08:00
Iván Rodríguez Murillo
5c0e88b4a7 Replaced System.out call with logger.debug. Fixes gh-962 2022-11-21 18:29:15 +00:00
Oleg Zhurakousky
9491c9ce04 GH-958 Add support for default routing
Resolves #958
2022-11-17 11:27:32 +01:00
Oleg Zhurakousky
04df79482d GH-939 & GH-956 Fix Kotlin function registration regression
Resolves #939
Resolves #956
2022-11-14 15:01:19 +01:00
Oleg Zhurakousky
672066b43a GH-932 Fix registration of AWSTypesMessageConverter for functional spring applications
Resolves #932
2022-11-10 12:17:21 +01:00
Oleg Zhurakousky
fd5a78e8a9 Make CloudEventsFunctionExtensionConfiguration public 2022-11-09 10:20:19 +01:00
Oleg Zhurakousky
643f360a54 Enhance JsonMessage converter to handle byte[] 2022-11-03 18:08:52 +01:00
Neokeld
acf86d53bd functionRegistration cant be null
Resolves #950
2022-11-02 10:07:07 +01:00
Oleg Zhurakousky
c7b2f7ebb4 GH-949 Clean up output conversion logic
Resolves #949

polish
2022-11-01 13:13:52 +01:00
Neokeld
73a1b5fa11 mcList is always not empty 2022-10-31 10:51:13 +01:00
Oleg Zhurakousky
4c83f34c9b Remove deprecations 2022-10-25 16:21:06 +02:00
Oleg Zhurakousky
fd65decdb6 GH-944 Remove deprecations and update documentation for MessageRoutingCallback
Resolves #944
2022-10-25 16:01:06 +02:00
Oleg Zhurakousky
32d18786c2 polish 2022-10-24 17:25:18 +02:00
Oleg Zhurakousky
09b1317620 Refactor and simplify Observability related code 2022-10-24 17:14:41 +02:00
Oleg Zhurakousky
5cfa934da3 Change conditional on ObservationAutoConfiguration 2022-10-24 13:01:25 +02:00
Marcin Grzejszczak
d627742772 Removes the producer and sender observations 2022-10-21 13:28:12 +02:00
Oleg Zhurakousky
deabd62093 Change sleuth enable property to observability enable 2022-10-20 16:33:45 +02:00
Oleg Zhurakousky
eb63634c83 Polishing Observability changes 2022-10-20 14:48:30 +02:00
Oleg Zhurakousky
55aad155f8 General code cleanup 2022-10-20 11:26:07 +02:00
Oleg Zhurakousky
857fa022f4 Polishing previous observability comit 2022-10-20 11:12:58 +02:00
Marcin Grzejszczak
d4917dc8a7 Fixed Observability module to work with Sender and Receiver contexts 2022-10-19 21:00:16 +02:00
Oleg Zhurakousky
9f0d53ad59 Initial Observability refactoring
Disconnect Observability module
MOve observability code to context

polish

Polish
2022-10-19 18:08:16 +02:00
Neokeld
e6985724d9 Simple refactor: function is always null, see l121
Resolves #934
2022-10-18 15:03:52 +02:00
Oleg Zhurakousky
ac5fdbae0f Remove un-used imports 2022-10-17 16:31:58 +02:00
Oleg Zhurakousky
2301eac68b Clean up in JsonMessageConverter
This is also to ensure that we can completely remove ApplicationJsonMessageMarshallingConverter from s-c-stream
2022-10-17 16:06:34 +02:00
Oleg Zhurakousky
4210b9333b GH-936 Add post processor for native hints
Resolves #936
2022-10-13 16:52:21 +02:00
Oleg Zhurakousky
c88d02cbd9 Revert "Set 'proxyBeanMethods' to false"
This reverts commit 4da2fab5b8.
2022-10-05 21:02:33 +02:00
Oleg Zhurakousky
4da2fab5b8 Set 'proxyBeanMethods' to false 2022-10-05 09:29:04 +02:00
Oleg Zhurakousky
2190f3a0a6 Additional deprecation removals 2022-09-28 17:22:27 +02:00
Oleg Zhurakousky
130c25f4dc Cleanup deprecations 2022-09-28 15:48:00 +02:00
Oleg Zhurakousky
f2073600ad Polishing 2022-09-22 20:45:18 +02:00
Oleg Zhurakousky
83980d34e1 Add new spring-boot .imports files and move auto-configuration classes there 2022-09-22 17:01:33 +02:00
Oleg Zhurakousky
14b47350cf Polishing the last commit 2022-09-20 18:44:41 +02:00
Oleg Zhurakousky
586aa7afa4 GH-925 Fix regression with Kotlin @Component regstration
Resolves #925
2022-09-20 18:07:18 +02:00
Oleg Zhurakousky
e44c00f0ee Add fallback to type discovery in FunctionContextUtils 2022-09-14 11:34:24 +02:00
Oleg Zhurakousky
0abfeee528 GH-924 Fix regression with structured CE cnversion into Message
Resolves #924
2022-09-08 16:20:43 +02:00
Soby Chacko
c8109270d2 Remove AVRO message converters in 4.0.x
Since we are migrating Schema Registry to Spring Cloud Stream,
the AVRO message converters in Spring Cloud Function could reside
in Spring Cloud Stream as part of its Schema Registry.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/921

Resolves #922
2022-08-29 18:56:21 +02:00
Oleg Zhurakousky
e83b0dfabe GH-919 Fix regression that was modifying result message
Resolves #919
2022-08-24 16:19:22 +02:00
Oleg Zhurakousky
9ad68f40f8 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:38:14 +02:00
Oleg Zhurakousky
d222cb12d5 GH-917 Fix regression with sanitizing headers
Resolves #917
2022-08-16 16:43:18 +02:00
Oleg Zhurakousky
12f45f1507 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:55 +02:00
Oleg Zhurakousky
8999337255 GH-909 Fix spelling of the method
Resolves #909
2022-08-08 15:33:27 +02:00