SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
2,115 Commits 22 Branches 0 Tags
90f7565e645110a740f9f353ebb1a97b56518451
Commit Graph

656 Commits

Author SHA1 Message Date
Oleg Zhurakousky
766cf9e9d8 GH-1163 Ignore FAIL_ON_UNKNOWN_PROPERTIES in Json conversion 
The regression is due to tye fact that we no longer using boot provided ObjectMapper and instead rely on our own instance

Resolves #1163
 2024-07-17 17:19:58 +02:00
Oleg Zhurakousky
da91630320 GH-STREAM-2971 Properly handle Kafka tombstone payload conversion 2024-07-17 16:09:53 +02:00
Oleg Zhurakousky
d8e67c8df9 GH-1149 Remove condition on FunctionCatalog 
It actually no longer required. It was added when certain other auto-configurations were present that are no longer exist, so effectively it was a leftover

Resolves #1149
 2024-07-09 12:30:02 +02:00
Oleg Zhurakousky
6ca9ad6526 GH-1157 Fix JSON logging in AWS 
Resolves #1157
 2024-07-03 11:43:06 +02:00
Victor Hugo Pongolino
23a69512df Fix typo in docs replacing FunctionRoutingResult to String in MessageRoutingCallback 2024-06-27 17:14:28 -03:00
Oleg Zhurakousky
5e73a6824c GH-1148 Add JavaTimeModule to ObjectMapper 2024-06-12 16:07:34 +02:00
Oleg Zhurakousky
8b66fd296e GH-1148 Configure our own ObjectMapper 2024-06-07 08:02:59 +02:00
Oleg Zhurakousky
b17795dd66 Revert "GH-1148 Remove manual setting of ObjectMapper feature" 
This reverts commit 812c39eccb.
 2024-06-07 07:54:51 +02:00
Oleg Zhurakousky
6ffae9397a GH-1141 Add support for composing reactive Supplier/Function with imperative Consumer 
Resolves #1141
 2024-06-06 11:38:19 +02:00
akenra
faeb0f77ad GH-1106 Fix RoutingFunction fail when "spring.cloud.function.definition" header contains a List value instead of a String value (GCP-specific) 
Resolves #1106
Resolves #1146
 2024-06-05 15:11:36 +02:00
Oleg Zhurakousky
812c39eccb GH-1148 Remove manual setting of ObjectMapper feature 
Remove manual setting of ObjectMapper feature in favor of standard Spring Boot via property setting

Resolves #1148
 2024-06-05 14:59:31 +02:00
Oleg Zhurakousky
05416dbc30 GH-STREAM 2704 Fix Consumer CCE on Kotlin Consumer 
Resolves #2704
 2024-05-31 15:53:40 +02:00
Oleg Zhurakousky
67180ac1a1 1144 Fix propagation of skipInputConversion 
Resolves #1144
 2024-05-27 13:39:41 +02:00
Oleg Zhurakousky
066f3d1c48 GH-1145 Fix List conversion for Function<Message<List>, ..> 
Resolves #1145
 2024-05-09 16:39:01 +02:00
Oleg Zhurakousky
c0f4cba30d GH-1140 Add data masking capabilities for JSON logging 
Resolves #1140
 2024-04-30 15:20:56 +02:00
Oleg Zhurakousky
59fe298b67 GH-1139 Fix function composition with non-existing functions 
Resolves #1139
 2024-04-29 16:57:37 +02:00
Soby Chacko
d38ab942bd GH-1134: Fix NPE in SimpleFunctionRegistry#isExtractPayload() 
Resolves https://github.com/spring-cloud/spring-cloud-function/issues/1134
 2024-04-09 16:17:36 -04:00
Oleg Zhurakousky
be45a47818 GH-1094 Refactor JSON string parsing 
It appears that primitive way of checkong for {} amd [] did not play well with protobuf so this commit represnts alternative approach

Resolves #1094
 2024-03-27 22:54:10 +01:00
Oleg Zhurakousky
d70079eb4d GH-1117 Enhance support for function composition to handle null returns 
Resolves #1117
 2024-03-27 19:05:21 +01:00
Oleg Zhurakousky
8745f32ac2 GH-1097 Ensure empty POJO converted to {} instead of null 
Resolves #1097
 2024-03-27 18:31:32 +01:00
Oleg Zhurakousky
aceae479d5 GH-1121 Change login levels on RoutingFunction 
Resolves #1121
 2024-03-27 16:45:11 +01:00
Romain
f9954d7dbd style: code simplification 
Resolves #1129
 2024-03-27 16:33:37 +01:00
sheheryar aamir
7969d06fc8 GH-1127 Fix String cast to OffsetDateTime issue for CloudEventMessageUtils 
Resolves #1127

Resolves #1128
 2024-03-27 16:26:18 +01:00
Oleg Zhurakousky
0d4b12f620 Add KotlinUtils to the repo 2024-03-26 16:52:35 +01:00
Oleg Zhurakousky
caee17dd75 Add KotlinUtils 2024-03-26 16:48:51 +01:00
Oleg Zhurakousky
3931ea4f14 GH-1104 Add support for case insensitive routing header names 
Resolves #1104
 2024-01-31 13:53:24 +01:00
Sergey Zolotarev
0f6aaaec45 Update function definition name in log message to avoid confusion 
Resolves #1102
 2024-01-31 11:00:11 +01:00
Jeffrey Douangpaseuth
fb0af94da2 fix JsonMessageConverter mimetype NPE 2024-01-30 17:21:53 -05:00
Oleg Zhurakousky
7e85c360bd Disable FAIL_ON_EMPTY_BEANS feature 2023-11-30 17:11:50 +01:00
Oleg Zhurakousky
8e9948c4c3 GH-1075 Fix conversion of complex types 
Resolves #1075
 2023-10-13 10:25:35 +02:00
Oleg Zhurakousky
afb419d701 GH-1063 Fix header propagation in composed function 
Resolves #1063
 2023-09-25 13:11:59 +02:00
Oleg Zhurakousky
42336c852c GH-1071 Add getter for Message in FunctionContext 2023-09-25 10:31:02 +02:00
Soby Chacko
19d1f320de GH-1060 Fix KafkaNull regression issue 
Fixing a KafkaNull related regression issue where consumers
receive null values for payload erasing any headers completely.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/1060
 2023-08-30 12:33:41 -04:00
Oleg Zhurakousky
9f04138e4f GH-1065 Fix Collection discovery in JsonMapper 
Resolves #1065
 2023-08-30 15:22:52 +02:00
Chris Bono
7bc499ddea Do not convert text/plain content to JSON 
Fixes bug and removes test comments from previous commit.

Resolves #1056
 2023-08-07 14:22:52 +02:00
Chris Bono
c97c0b2a96 Add tests to illustrate the bug 2023-08-07 14:16:18 +02:00
Oleg Zhurakousky
aff82e1457 GH-1052 Fix collection/array processing for AWS invocations with Publisher input type functions 
Resolves #1052
 2023-07-13 15:22:40 +02:00
Oleg Zhurakousky
351e73b7f4 GH-992 Add MessageUtils AOT hints 
Resolves #992
 2023-07-11 14:46:39 +02:00
Oleg Zhurakousky
6969ec9720 GH-1043 Add support for communicating type via MimeType parameter for JsonMessageConverter 
Resolves #1043
 2023-06-01 16:58:46 +02:00
Oleg Zhurakousky
e3a44c3cf3 Ensure RoutingFuunction can't route to itself 2023-04-25 13:21:25 +02:00
Oleg Zhurakousky
71243f2179 GH-1023 Add no-op apply method to PostProcessingFunction 
Resolves #1023
 2023-04-18 13:14:11 +02:00
Oleg Zhurakousky
278d917543 GH-1023 Add support for post function processing 2023-04-18 13:14:03 +02:00
Oleg Zhurakousky
55eb78190c GH-1017 Ensure conversionHint is properly interpreted 
Resolves #1017
 2023-03-28 10:07:53 +02:00
Soby Chacko
0ba011a903 Function wrapping BiConsumer improvements 
When a BiConsumer user function is provided, we wrap it inside a Function
when registering it in FunctionRegstration. FunctionInvocationWrapper sees
this as a Function and downstream clients (such as Spring Cloud Stream) does
not have visibility into the user function type from a FunctionInvocationWrapper
API perspective. This commit propagates the BiConsumer targer user function info
as part of FunctionInvocationWrapper API.

For more information, see: https://github.com/spring-cloud/spring-cloud-stream/issues/2670
Resolves #1016
 2023-03-24 11:39:29 +01:00
Soby Chacko
dda6d3cb21 Unncessary warning for multiple functions found 
Currently we show a warning for multiple functions found even when there
are no functions found and spring.cloud.function.definition is not set.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/1011
 2023-03-09 16:26:41 -05:00
Oleg Zhurakousky
21dbe4cd1f GH-1002 Cleane up non-jackarta dependencies 
Resolves #1002
 2023-02-24 11:13:20 +01:00
nagarro-nikhiljagtiani
65b17b820c Avoiding classCast exception 
Resolves #991

When messageconverters list has CloudEventMessageConverter before AvroSchemaRegisteryClientMessageConverter,
and message has header contentType = application/*+avro
It results in ClassCastException hence fixing the same.
 2023-02-22 14:13:40 +01:00
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