Commit Graph

99 Commits

Author SHA1 Message Date
Oleg Zhurakousky
2f425abb3f Minor simplification in FunctionRSocketMessageHandler 2021-03-17 14:58:35 +01:00
Oleg Zhurakousky
93ce61f5ab RSocket - Add Cbor test, fixed consumer test and minor cleanup
polish
2021-03-16 20:53:48 +01:00
buildmaster
dd00e15102 Bumping versions to 3.1.3-SNAPSHOT after release 2021-03-16 13:20:48 +00:00
buildmaster
395097bc63 Going back to snapshots 2021-03-16 13:20:47 +00:00
buildmaster
a27e3620a3 Update SNAPSHOT to 3.1.2 2021-03-16 13:17:55 +00:00
Oleg Zhurakousky
d509640827 GH-667 Ensure delegation to other available argument resolvers
In RSocket module we provide custom argument resolver that is aware of how to create a Message if incoming data is application/json
However in the event it's anything else, this fix ensures that there is a delegation model to give other argument resolvers a chance

Resolves #667
2021-03-16 13:00:37 +01:00
Oleg Zhurakousky
51dd8cf1d5 Fix encoder/decoder to return decodableMimeTypes
This effectively fixes the Cbor exclusiion
2021-03-15 12:23:27 +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
2dea991c3e Fix header propagation for rsocket message 2021-03-10 15:25:50 +01:00
Oleg Zhurakousky
485d6967bd Fix checkstyle 2021-03-10 06:51:01 +01:00
Oleg Zhurakousky
9f8c29a4e7 Remove dependency on web classes from new Encoder/Decoder implementation
The web dependency still need to be there since it appears that spring-rsocket requires it
2021-03-05 15:08:25 +01:00
Oleg Zhurakousky
c8a0cebd1f Cleanup 'handleAndReply' logic in RSocketListenerFunction 2021-03-05 09:51:59 +01:00
Oleg Zhurakousky
157949df93 Fix Message sanitizing logic in FunctionRSocketUtils
Only sanitize headers that are not serializable
2021-03-05 08:43:19 +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
c798910e33 Polish documentation 2021-03-03 08:18:19 +01:00
Oleg Zhurakousky
ec2f4a2b4e Polish documentation 2021-03-03 08:17:19 +01:00
Oleg Zhurakousky
b45feef677 Polish documentation 2021-03-03 08:01:19 +01:00
Oleg Zhurakousky
0a28d57da3 Polish documentation 2021-03-03 07:59:10 +01:00
Oleg Zhurakousky
8ecf72c50e Update documentation with distributed function composition 2021-03-03 07:51:30 +01:00
Oleg Zhurakousky
201841418d GH-660 Update RSocket documentation with Messaging bits 2021-03-03 07:26:51 +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
9f1c99bae8 GH-654 Update routing and RSocket routing documentation with details on 'MessageRoutingCallback'
Resolves #654
2021-02-24 15:48:34 +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
40d0507609 GH-654 Fix how RoutingFunction is treated by RSocketListenerFunction 2021-02-23 16:58:37 +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
buildmaster
36de6289ba Bumping versions 2021-02-01 18:56:47 +00:00
buildmaster
44d583493a Bumping versions 2021-01-27 18:56:44 +00:00
buildmaster
d6fb9cfaf8 Bumping versions to 3.1.2-SNAPSHOT after release 2021-01-27 17:16:38 +00:00
buildmaster
329a805fcf Going back to snapshots 2021-01-27 17:16:37 +00:00
buildmaster
047f5f95cb Update SNAPSHOT to 3.1.1 2021-01-27 17:11:29 +00:00
Oleg Zhurakousky
b2e783490c Fix RSocket CloudEvents sample 2021-01-27 15:29:16 +01:00
Oleg Zhurakousky
099671bb3a Revert "Bumping versions"
This reverts commit 1356831897.
2021-01-14 12:36:38 +01:00
buildmaster
1356831897 Bumping versions 2021-01-13 18:56:32 +00:00
Oleg Zhurakousky
ffbc7fec78 Revert "Bumping versions"
This reverts commit da075793f6.
2021-01-11 10:44:04 +01:00
buildmaster
da075793f6 Bumping versions 2020-12-21 18:56:08 +00:00
Oleg Zhurakousky
fde7da34d1 Fix snapshot versions 2020-12-21 18:04:32 +01:00
buildmaster
48605a9ac3 Bumping versions to 3.1.1.SNAPSHOT after release 2020-12-21 11:57:51 +00:00
buildmaster
d7fc2a251e Going back to snapshots 2020-12-21 11:57:50 +00:00
buildmaster
902c9f94e0 Update SNAPSHOT to 3.1.0 2020-12-21 11:54:46 +00:00
Oleg Zhurakousky
e20fadbeae GH-590 change README extension 2020-12-21 10:28:21 +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