Commit Graph

712 Commits

Author SHA1 Message Date
Oleg Zhurakousky
b1a6fc4994 KafkaNull batch attempt 2022-06-07 21:22:25 +02:00
Oleg Zhurakousky
724ba06c11 Fix FunctionTypeUtils as well as LocalServerPort issue
Resolves #871
2022-06-07 16:01:50 +02:00
Artem Bilan
66b88f2f1e FunctionTypeUtils test for NPE
Related to https://stackoverflow.com/questions/72163534/spring-batch-integration-throwns-org-springframework-messaging-messagehandlingex

The `FunctionTypeUtils.isMessage()` fails with NPE
when target method has non-message argument with generic parameter.
Even if we instantiate the class with specific generic argument,
that info is not available for reflection and `MethodParameter`
end up with a generic parameter name which is essentially a `TypeVariable`

The stacktrace is like this:
```
java.lang.NullPointerException: Cannot invoke "java.lang.Class.getGenericInterfaces()" because "targetType" is null

	at net.jodah.typetools.TypeResolver.getTypeVariableMap(TypeResolver.java:494)
	at net.jodah.typetools.TypeResolver.resolveRawClass(TypeResolver.java:387)
	at net.jodah.typetools.TypeResolver.resolveRawClass(TypeResolver.java:373)
	at org.springframework.cloud.function.context.catalog.FunctionTypeUtils.isMessage(FunctionTypeUtils.java:416)
```
2022-06-07 15:21:09 +02:00
Oleg Zhurakousky
4661ab186b GH-873 Fix JsonNode conversion
Resolves #873
2022-05-30 14:39:03 +02:00
Oleg Zhurakousky
085ae9f620 GH-878 Fix concurrency issue during registration and lookup of functions
Resolves #878
2022-05-30 12:11:36 +02:00
Oleg Zhurakousky
3aa3c4a2c3 GH-865 Added initial test for Observability module
Resolves #865
2022-05-10 15:23:12 +02:00
Oleg Zhurakousky
bef1b018d0 GH-739 Add DEBUG log statement for when type conversion fails
Resolves #739
2022-05-04 14:59:38 +02:00
Oleg Zhurakousky
3bfa5faa44 GH-791 Add support for propagating input headers
Resolves #791

polishing merge
2022-05-04 14:48:14 +02:00
Oleg Zhurakousky
536bd3920f Remove observability 2022-05-03 19:48:16 +02:00
Oleg Zhurakousky
82e090d163 GH-856 Fix logic in determining Cloud Event prefix
Resolves #856
2022-04-26 08:39:26 +02:00
REMY David
eee99c051b Change OffsetTime to OffsetDateTime in CloudEventMessageUtils
Resolves #855
2022-04-21 11:03:44 +02:00
Oleg Zhurakousky
bbac4b198e Fix handling of collections by non-reactive Consumers 2022-04-06 17:23:48 +02:00
spencergibb
470eda85a7 Revert "Remove io.micrometer.observation code"
This reverts commit 830a7e7cc2.
2022-03-31 16:09:58 -04:00
buildmaster
343aac3eff Going back to snapshots 2022-03-31 17:26:24 +00:00
buildmaster
b1779fe50b Update SNAPSHOT to 4.0.0-M2 2022-03-31 17:22:24 +00:00
spencergibb
830a7e7cc2 Remove io.micrometer.observation code 2022-03-31 13:05:24 -04:00
Oleg Zhurakousky
2606a317c2 Fix Observability package change structure 2022-03-31 16:29:16 +02:00
Oleg Zhurakousky
51cca8840e Fix conversion logic in SmartCompositeMessageConverter 2022-03-25 14:24:18 +01:00
Oleg Zhurakousky
97a55a3608 GH-828 Add support for configuring additional routers
Resolves #828
2022-03-24 18:26:41 +01:00
Oleg Zhurakousky
bbf56b0744 GH-830 Fix conversioin exception for custom converters
Resolves #830
2022-03-23 17:17:49 +01:00
Oleg Zhurakousky
e09954913e GH-832 Change OffsetTime to OffsetDateTime in CloudEventMessageBuilder
Resolves #832
2022-03-23 13:17:35 +01:00
Oleg Zhurakousky
2ce45726ab Performance improvements related to SCST-2303 2022-03-22 13:53:48 +01:00
Oleg Zhurakousky
5ef56a90f0 checkstyle 2022-03-21 16:37:18 +01:00
Oleg Zhurakousky
c5f176b978 Perf improvement 2022-03-18 14:47:44 +01:00
Oleg Zhurakousky
b777988086 Add SocketUtils 2022-03-17 16:10:34 +01:00
Oleg Zhurakousky
bb3f33f1c5 Fix deprecations and breaking changes caused by dependencies 2022-03-17 14:59:04 +01:00
Oleg Zhurakousky
d18ca9790f Merge pull request #818 from FalkWoldmann6232/main
Fix typo
2022-03-08 15:14:54 +01:00
Oleg Zhurakousky
a364aaf86a GH-823 Polishing
Resolves #823
2022-03-04 17:03:07 +01:00
Marcin Grzejszczak
ea3be5ef39 GH-823 Add initial support for Observability 2022-03-04 16:59:43 +01:00
FalkWoldmann6232
d398449eae Fix typo 2022-02-24 12:44:48 +01:00
onobc
dc52af8df6 Improve ContextFunctionCatalogAutoConfiguration conditional loading
- Allow custom AvroSchemaServiceManager to be used
- Make AvroSchemaMessageConverter bean method specifically typed
- Make CloudEventsMessageConverter bean method specifically typed
- Add tests focusing on the conditional loading aspects of the auto configuration

Fixes gh-797
Resolves #814
2022-02-23 15:43:15 +01:00
Oleg Zhurakousky
be031cd315 GH-816 Enhance test validating collection output 2022-02-23 15:08:18 +01:00
Oleg Zhurakousky
95f9fbf417 Revert "GH-816 Fix support for function that returns Iterable with target-protocol set"
This reverts commit ed6642e18e.
2022-02-23 12:18:17 +01:00
Oleg Zhurakousky
ed6642e18e GH-816 Fix support for function that returns Iterable with target-protocol set
Resolves #816
2022-02-21 14:50:29 +01:00
Roman S Samarev
18677ca47c SimpleFunctionRegistry: Fixed: compose of supplier...consumer pipeline produces a supplier type. This fix allows testing of composed pipelines without input and output
SimpleFunctionRegistry: added info. No functional changes

Resolves #809
2022-02-15 20:31:55 +01:00
Soby Chacko
d49637c349 Revert "Remove skipConversion in FunctionAroundWrapper"
This reverts commit 240098fa10.
2022-02-11 12:38:51 -05:00
Soby Chacko
609035b918 Revert "* Simplify functionalTracingEnabled variable logic"
This reverts commit 159c82e4a9.
2022-02-11 12:38:40 -05:00
Soby Chacko
7704c2f530 Revert "fix checkstyle"
This reverts commit c6e32cbd42.
2022-02-11 12:38:15 -05:00
Oleg Zhurakousky
2d59a0d759 GH-804 Add support for case-insensitive Cloud Event determination
Resolves #804
2022-02-09 14:23:21 +01:00
Oleg Zhurakousky
5b4cec0db3 GH-804 Add support for case-insensitive routing 2022-02-09 13:58:01 +01:00
Oleg Zhurakousky
bb3c62a3cd GH-796 Fix error handling for reactive input/ouput conversion
Resolves #796
2022-02-07 18:56:18 +01:00
Oleg Zhurakousky
c6e32cbd42 fix checkstyle 2022-02-07 15:19:58 +01:00
Artem Bilan
159c82e4a9 * Simplify functionalTracingEnabled variable logic
* Add `BeanFactoryAwareFunctionRegistryTests.testWrappedWithAroundAdviseNotMessageReturnConfiguration()`
to verify that non-Message return from the target function is wrapped to the `Message` before return
to the `FunctionAroundWrapper`
2022-02-07 15:09:51 +01:00
Artem Bilan
240098fa10 Remove skipConversion in FunctionAroundWrapper
Currently, the `FunctionAroundWrapper` set `targetFunction.setSkipOutputConversion(true);`
which is not what expected by the `TraceFunctionAroundWrapper`.
This one has a logic based on the `Message` as an output from the target function
and its headers to correlate tracing headers.

* Remove the `setSkipOutputConversion(true)` from the `FunctionAroundWrapper`
to satisfy `TraceFunctionAroundWrapper` expectation - we cannot enforce
all the end-user function to always return a `Message<?>` for us.
* Some other refactoring in the `FunctionAroundWrapper` for cleaner code

**Cherry-pick to `3.2.x`**
2022-02-07 15:09:51 +01:00
Oleg Zhurakousky
19df9928a2 GH-802 Add exclusion filter to component scanning to ignore Spring annotated classes
Resolves #802
2022-02-07 15:06:05 +01:00
salaboy
a3b4e92137 fixing whcih typo 2022-02-03 09:29:46 +00:00
buildmaster
9fcf6f8db8 Going back to snapshots 2022-01-27 13:00:22 +00:00
buildmaster
1c9df288c0 Update SNAPSHOT to 4.0.0-M1 2022-01-27 12:56:33 +00:00
Oleg Zhurakousky
536d3d6e80 GH-794 Address regression with input type conversion of Maps
Resolves #794
2022-01-26 12:51:13 +01:00
Oleg Zhurakousky
012a4daa59 Cleanup and additional test 2022-01-24 16:19:26 +01:00