SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,351 Commits 22 Branches 0 Tags
26ed4cbb2572dfdfdb36349043b3b1697c3c8fd0
Commit Graph

446 Commits

Author SHA1 Message Date
Oleg Zhurakousky
eca03a49d8 Re-enable FunctionAroundWrapper 2021-07-28 11:26:23 +02:00
Oleg Zhurakousky
166937cdab Temporarily disabled calls to FunctionAroundWrapper 2021-07-26 17:18:31 +02:00
Oleg Zhurakousky
0403c2e107 GH-717 Change List to Collection 2021-07-26 13:48:01 +02:00
Oleg Zhurakousky
7d1ef3474f GH-717 Add support for adding MessageConverters to FunctionCatalog 
Resolves #717
 2021-07-26 13:10:52 +02:00
Oleg Zhurakousky
ff7741ea74 GH-713 Add support for default function for HTTP 
Resolves #713
 2021-07-14 14:46:21 +02:00
Oleg Zhurakousky
98721d741c Put guard to make sure reactve supplier is not instrumented by sleuth 2021-07-09 16:20:15 +02:00
Oleg Zhurakousky
9fffafb4d3 GH-711 Add initial support for source/target types determination 
Resoves #711
 2021-07-01 17:06:15 +02:00
Oleg Zhurakousky
f9e6726188 GH-710 Fix output conversion logic for when Function is wrapped in around advice 2021-06-28 19:02:34 +02:00
Oleg Zhurakousky
d7039b309f GH-710 Set skipOutputConversion flag is FunctionAroundWrapper is present 
Resolves #710
 2021-06-28 17:13:26 +02:00
Oleg Zhurakousky
2f9f7e10bd Add support for handling Supplier to FunctionAroundWrapper 2021-06-17 10:42:39 +02:00
Oleg Zhurakousky
5a625b4ad0 GH-708 Initial refactoring and consolidation of s-c-function-web MVC part. 2021-06-15 15:15:26 +02:00
Oleg Zhurakousky
378f0d33ab GH-707 Fix Concurrent Modification exception on lookup 
Rare condition but it appears that in some runtimes there could be multiple threads invoking lookup operation
Added test to validate

Resolves #707
 2021-06-08 14:07:32 +02:00
Oleg Zhurakousky
e419b41968 GH-676 Fix mixed (index and not) input-header-mapping-expression 2021-05-26 15:21:12 +02:00
Oleg Zhurakousky
ad8f9dd044 Temporary fix for s-c-stream GH-2178 
This removes 'spring.cloud.stream.sendto.destination' headers from each incoming message
 2021-05-26 14:09:42 +02:00
Oleg Zhurakousky
8737a60321 GH-676 Add javadoc and minor polishing 2021-05-25 11:50:13 +02:00
Oleg Zhurakousky
22e945009a GH-676 Relax SpEL evaluation failures for input header enrichment 
Add documentation

Resolves #676
 2021-05-24 15:18:28 +02:00
Tsypov Dmitriy
9e8d7d3d19 Fixed a bug where the consumer function could not subscribe to the incoming flow 
Resolves #701
Resolves #702
 2021-05-24 13:59:19 +02:00
Oleg Zhurakousky
79f4540130 GH-676 Add split condition test for header enrichment 2021-05-20 07:32:49 +02:00
Tsypov Dmitriy
0db0a2f555 GH-699 Fixed a bug where Kotlin Lambda was incorrectly converted to a consumer function 
Fixed consumer type

Fixed tests

Added javadoc @author tag

Resolves #699
Resolves #700
 2021-05-20 06:58:10 +02:00
Oleg Zhurakousky
238ac301df GH-676 Improvements to header enrichment 2021-05-19 16:52:50 +02:00
Oleg Zhurakousky
03de819c4a GH-676 Add initial support for mapping/re-mapping input headers 
Add BeanResolver
 2021-05-14 10:16:41 +02:00
Oleg Zhurakousky
cfec6eceec Change deprecate json mapper property 
Resolves #693
 2021-05-11 15:51:09 +02:00
Oleg Zhurakousky
8e5a9facde Add javadoc on new public method 
Resolves #690
 2021-04-26 15:16:47 +02:00
Soby Chacko
e16be9c50d GH-689: Native compilation related changes 
Provide mutator/accessor for enhancer filed in FunctionInvocationWrapper
in SimpleFunctionRegistry. This is required by graalvm native compilation in
Spring Cloud Stream applications.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/689
 2021-04-22 19:57:50 -04:00
Oleg Zhurakousky
5e824f33aa polishing 2021-04-15 16:52:04 +02:00
Oleg Zhurakousky
6f6c87a134 GH-680 Add additional DEBUG logging to CloudEventsFunctionInvocationHelper 2021-04-14 20:01:54 +02:00
Oleg Zhurakousky
727322b1f0 GH-680 Add support for strict (or not) dependency on target-protocol header for CE 
Resolves #680
 2021-04-14 18:49:01 +02:00
Oleg Zhurakousky
ecd9902ced GH-685 Move Kotlin configurations to s-c-function-context module 
Resolves #685
 2021-04-12 15:02:56 +02:00
Oleg Zhurakousky
ee0bc4e28f Merge additional test to ensure propper type conversion 2021-04-10 08:10:23 +02:00
Taras Danylchuk
5afbd25d1c gh-608 issue 2021-04-10 07:59:38 +02:00
Oleg Zhurakousky
a4c1358af4 GH-677 Add spring.cloud.function.preferred-json-mapper property 
Deprecate spring.http.converters.preferred-json-mapper
Resolves #677
 2021-04-09 15:50:50 +02:00
Oleg Zhurakousky
2e133f9e9a Add test for FunctionAroundWrapper 2021-04-08 17:10:17 +02:00
Oleg Zhurakousky
b2f36936ac GH-662 Fix support for reactive functions in AWS 
This commit also includes other minor fixes around CustomRuntime which was getting in the way of this specific issue
 Added lookup for _HANDLER env variable
 Added few tests (will need more)
 Added support for Iterable for reactive functions

Resolves #662
 2021-04-08 15:57:14 +02:00
Oleg Zhurakousky
c0ed41f9c7 GH-679 Add test to validate output conversion for composed functions 
Resolves #679
 2021-04-07 11:53:17 +02:00
Oleg Zhurakousky
004813dfd2 Fix NPE possibility for ConversionService not being present in the Bean Factory 2021-04-01 13:56:35 +02:00
Oleg Zhurakousky
a88a8be223 Simplify FunctionInvocationHelper and its CE implementation 2021-03-24 16:31:41 +01:00
Oleg Zhurakousky
c871e5722a Polishing SDK CloudEvent integration 2021-03-19 15:52:57 +01:00
Oleg Zhurakousky
675889f549 Provide initial integration with SDK CloudEvent 2021-03-19 15:00:02 +01:00
Soby Chacko
be50084118 Array reification error with KStream[] in Kotlin 
Exclude Kafka Streams functions with KStream[] return type as this
causes some array reification errors in Kotlin.

See this issue for more details: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1044

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

Resolves #670
 2021-03-18 19:58:07 +01:00
Oleg Zhurakousky
e82f54d69e GH-600 Fix logic in Azure adapter to ensure proper handling of sveral functions 
This also addresses re-initialization of AC when the second function is invoked
Added second function to the azure examples

Resolves #600
 2021-03-11 15:26:06 +01:00
Oleg Zhurakousky
29ad49cbf6 GH-437 Pass ExecutionContext via MessageHeader 
Caching it as part of ApplicationContext was not the right idea so this changes it
 2021-03-10 18:53:25 +01:00
Oleg Zhurakousky
cf7a990480 Polish JsonMapper and upgrade function dependency in azure adapter 2021-03-10 16:31:17 +01:00
Oleg Zhurakousky
498a52ee84 GH-661 Fix KafkaNull as input type conversion 
Basically KafkaNull gets a special treatement where if we see it as Message payload and input type of the function is Message we give it as is and if the input type is POJO then we simply return null

Resolves #661
 2021-03-05 12:20:29 +01:00
Oleg Zhurakousky
f80d0de0a3 GH-660 Add initial suppport for sending/receiving Messages 
Resolves #660
 2021-03-03 06:38:33 +01:00
Oleg Zhurakousky
1f818dd639 GH-654 Remove FunctionProperties injection from MessageRoutingCallbackRSocketTests 2021-02-24 13:31:31 +01:00
Oleg Zhurakousky
9d6a23f102 GH-654 Add more tests, cleanup and initial javadoc 2021-02-24 08:49:53 +01:00
Oleg Zhurakousky
9093852854 GH-654 remove route(Publisher) from MessageRoutingCallback 2021-02-23 17:26:08 +01:00
Oleg Zhurakousky
3b8b110e0a GH-654 Initial support for non-SpEL based routing mechanism 2021-02-23 06:19:45 +01:00
Oleg Zhurakousky
8a71f37a4d SCST-GH-2115 Ensure that in a case of KafkaNull we just return a payload 2021-02-22 16:10:05 +01:00
Oleg Zhurakousky
a24713e53b GH-649 Ignire factory bean names during discovery of a function 
Resolves #649
 2021-02-15 17:53:12 +01:00