Commit Graph

55 Commits

Author SHA1 Message Date
Oleg Zhurakousky
f1e330a23c GH-1038 GH-834 Remove copy of TestSocketUtils
Resolves #1038
Resolves #834
2023-10-23 18:26:30 +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
3ab344c504 Fix merge issues
Resolves #826
2022-03-23 11:33:15 +01:00
onobc
0de3a5e7ea Fix search/replace typo. 2022-03-23 08:33:14 +01:00
onobc
8b589c67e5 Reduce use of SocketUtils in tests
Resolves #825
2022-03-23 08:33:14 +01:00
Oleg Zhurakousky
bb3f33f1c5 Fix deprecations and breaking changes caused by dependencies 2022-03-17 14:59:04 +01:00
spencergibb
21c9e9cf9d Updates broker to 0.3.0
Resolves #775
2021-12-01 08:59:10 +01:00
Oleg Zhurakousky
acc5548b54 GH-745 Fix conversion issue with json Strings and byte[]
Resolves #745
2021-09-22 12:11:00 +02:00
Oleg Zhurakousky
dc98f0b49f GH-709, GH-684, GH-641 Upgrade AWS dependency
Refactor and simplify AWSLambdaUtils to work with AWS serialization libraries
Add support for API v2 gateway event

Resolves #709
Resolves #684
Resolves #641
2021-07-22 18:57:57 +02:00
Oleg Zhurakousky
93ce61f5ab RSocket - Add Cbor test, fixed consumer test and minor cleanup
polish
2021-03-16 20:53:48 +01:00
Oleg Zhurakousky
ab84bb8a14 Add test assertions to validate header propagation for rsocket message 2021-03-10 15:38:13 +01:00
Oleg Zhurakousky
fcd427ca29 GH-663 Fix how strtategies are used to register additional encoders/decoders
Resolves #663
2021-03-05 08:08:16 +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
3b8b110e0a GH-654 Initial support for non-SpEL based routing mechanism 2021-02-23 06:19:45 +01:00
Oleg Zhurakousky
427669a97c Fix spelling error in constant name 2021-02-22 14:11:27 +01:00
Oleg Zhurakousky
386931966c GH-653 Retain original 'lookupDestination' while adding 'reconsiledLookupDestination'
This is necessary to retain user provided information while also prpviding a way to reconsile the actual destination/function
2021-02-22 14:08:02 +01:00
Oleg Zhurakousky
59d0314435 GH-652 Improve error messaging and function exist check
FunctionRSocketUtils looks up function by a bean name hen it attempts  to determine if there is a remote routing. That is not correct since bean name may not exist if function was manually registered. Also, the error message 'Must only contain one output redirect' was not clear as it was not showing the actual function name for propper debugging

Resolves #651
2021-02-22 12:19:57 +01:00
Oleg Zhurakousky
27acfd8cc3 GH-653 Add documentation and additional test to validate function definition order for RSocket
Resolves #653
2021-02-22 11:41:06 +01:00
Oleg Zhurakousky
56b3c49120 GH-653 Make consistent priority order of function definition in RSocket
With this commit spring.cloud.function.routing-expression property takes precedence over all, then route(<function.definition>) and then spring.cloud.function.definition property
2021-02-22 11:11:55 +01:00
Oleg Zhurakousky
a161dfa660 Simplified RoutingFunction configuration
If routing-expression is provided there is no need to explicitely set function.definition to 'functionRouter'
2021-02-18 15:35:26 +01:00
Oleg Zhurakousky
e437fa2181 Add initial RSocket test with RoutingFunction 2021-02-18 14:42:14 +01:00
Oleg Zhurakousky
b2e783490c Fix RSocket CloudEvents sample 2021-01-27 15:29:16 +01:00
Oleg Zhurakousky
d27dcbb7de GH-590 Add initial RSocket documentation 2020-12-21 10:26:55 +01:00
Oleg Zhurakousky
8ece3d3083 Add stream (kafka, Rabbit) and Rsocket examples for Cloud Event 2020-12-18 16:44:29 +01:00
Oleg Zhurakousky
14918ebf16 Clean up FunctionTypeUtils 2020-10-19 14:44:37 +02:00
Oleg Zhurakousky
72f05fc591 Refactor FunctionCatalog implementation 2020-10-16 17:59:06 +02:00
Oleg Zhurakousky
bf001bc754 Revert "Temporarily disable rsocket-routing-broker integration"
This reverts commit 63f655fb45.
2020-09-23 17:12:46 +02:00
Oleg Zhurakousky
63f655fb45 Temporarily disable rsocket-routing-broker integration 2020-09-23 16:24:01 +02:00
Oleg Zhurakousky
54b0b3b376 Re-enable routing broker tests after fixes in routing broker 2020-09-17 11:43:54 +02:00
Oleg Zhurakousky
e19ed2ff68 GH-587 Add support for inferring 'accept' content type for simple types
This fix also introduces new Function property 'accept' with no default value which implicitely would default to application/json unless the output type of the function is String at which point it would default to text/plain. However, if it was explicitely set in FunctionProperties it will be used regardless of the function output type.
Resolves #587
2020-09-16 18:14:40 +02:00
Oleg Zhurakousky
a057fea6b0 Remove dead code from FunctionRSocketMessageHandler
Add and clean up tests
2020-09-02 08:27:51 +02:00
Oleg Zhurakousky
f2f1432912 GH-585 Add initial support for passing/parsing Message headers
This woudl allow Message headers to be passed as JSON string via rsocket metadata

Resolves #585
2020-09-01 13:21:58 +02:00
Spencer Gibb
d120f49025 Updates to new routing client broker tcp properties 2020-08-31 19:14:58 -04:00
Spencer Gibb
940aab1e31 Re-enables RoutingBrokerTests
Also updates comments on `.route("uppercase")` as this is now required for `FunctionRSocketMessageHandler`
2020-08-28 10:45:59 -04:00
Oleg Zhurakousky
4007b88efb Temporary disabling of RoutingBrokerTests 2020-08-28 09:16:05 +02:00
Oleg Zhurakousky
123ced3fb6 Fix distributed composition test
Added override of handleMessage(..) to FunctionRSocketMessageHandler to be able to register functions on demand instead of pre-registering all of them during the init
2020-08-28 09:14:57 +02:00
Spencer Gibb
6554d27751 Updates property based metadata to use uppercase function name 2020-08-27 13:51:21 -04:00
Oleg Zhurakousky
afcf85d23c Cherry-pick type of merge the work from Artem in #580
Resolves #580
2020-08-27 14:34:24 +02:00
Oleg Zhurakousky
9922a0ca32 Formatting test code 2020-08-26 15:23:31 +02:00
Oleg Zhurakousky
ddd95cda17 Ad initial support for propagating metadata as Message headers 2020-08-26 15:19:23 +02:00
Oleg Zhurakousky
18b0f436d3 Add RSocketRequester configuration for tests 2020-08-26 14:35:34 +02:00
Oleg Zhurakousky
c1240ebb91 Remove custom server creation logic and rely on boot instead
Resolves #579
2020-08-26 10:03:11 +02:00
Oleg Zhurakousky
30572cf0fc Polish RoutingBrokerTests 2020-08-25 21:20:11 +02:00
spencergibb
95016d27ba Uses renamed RoutingMetadata 2020-08-25 14:17:36 -04:00
spencergibb
045976321a Comment out SpringRouting 2020-08-25 12:16:34 -04:00
spencergibb
306dff3d0f Uses property based routing client request metadata 2020-08-25 12:14:01 -04:00
spencergibb
d02b6998c3 Migrates to using rsocket-routing-broker 2020-08-24 15:49:31 -04:00
spencergibb
f04e355026 Initial rsocket-broker sample 2020-08-24 15:22:52 -04:00