116 Commits

Author SHA1 Message Date
buildmaster
eb15c09525 Bumping versions 2023-05-27 12:59:21 +00:00
buildmaster
20723d4bb8 Bumping versions to 3.1.8-SNAPSHOT after release 2022-03-29 14:53:19 +00:00
buildmaster
2dccf48806 Going back to snapshots 2022-03-29 14:53:19 +00:00
buildmaster
63b9313d1f Update SNAPSHOT to 3.1.7 2022-03-29 14:49:53 +00:00
buildmaster
5283554d7c Bumping versions to 3.1.7-SNAPSHOT after release 2021-12-14 08:47:53 +00:00
buildmaster
ac239ddf0e Going back to snapshots 2021-12-14 08:47:52 +00:00
buildmaster
2ece708178 Update SNAPSHOT to 3.1.6 2021-12-14 08:44:02 +00:00
buildmaster
5cfc9a7a53 Bumping versions to 3.1.6-SNAPSHOT after release 2021-10-22 09:36:31 +00:00
buildmaster
686722b1e1 Going back to snapshots 2021-10-22 09:36:30 +00:00
buildmaster
67728d0e38 Update SNAPSHOT to 3.1.5 2021-10-22 09:32:51 +00:00
Oleg Zhurakousky
96d494a9e8 GH-745 Fix conversion issue with json Strings and byte[]
Resolves #745
2021-09-22 12:18:34 +02:00
buildmaster
9e6e47e9e1 Bumping versions to 3.1.5-SNAPSHOT after release 2021-09-21 05:51:58 +00:00
buildmaster
af1c18e41d Going back to snapshots 2021-09-21 05:51:57 +00:00
buildmaster
d269d8d877 Update SNAPSHOT to 3.1.4 2021-09-21 05:48:12 +00:00
buildmaster
1864a09fc4 Bumping versions to 3.1.4-SNAPSHOT after release 2021-05-26 13:50:55 +00:00
buildmaster
40f1c2ad7c Going back to snapshots 2021-05-26 13:50:54 +00:00
buildmaster
af2298caaa Update SNAPSHOT to 3.1.3 2021-05-26 13:46:32 +00:00
Oleg Zhurakousky
1e42e82063 Minor simplification in FunctionRSocketMessageHandler 2021-03-17 14:58:35 +01:00
Oleg Zhurakousky
835f3cc723 RSocket - Add Cbor test, fixed consumer test and minor cleanup
polish
2021-03-16 20:53:48 +01:00
buildmaster
85515c12f9 Bumping versions to 3.1.3-SNAPSHOT after release 2021-03-16 13:20:48 +00:00
buildmaster
6fd1b8d1c4 Going back to snapshots 2021-03-16 13:20:47 +00:00
buildmaster
255c0f67c1 Update SNAPSHOT to 3.1.2 2021-03-16 13:17:55 +00:00
Oleg Zhurakousky
39fa045880 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
70744bb976 Fix encoder/decoder to return decodableMimeTypes
This effectively fixes the Cbor exclusiion
2021-03-15 12:23:27 +01:00
Oleg Zhurakousky
778672e6ea Add test assertions to validate header propagation for rsocket message 2021-03-10 15:38:13 +01:00
Oleg Zhurakousky
3255ae7455 Fix header propagation for rsocket message 2021-03-10 15:25:50 +01:00
Oleg Zhurakousky
73164beb68 Fix checkstyle 2021-03-10 06:51:01 +01:00
Oleg Zhurakousky
6f90410dda 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
e4cdd9b7a4 Cleanup 'handleAndReply' logic in RSocketListenerFunction 2021-03-05 09:51:59 +01:00
Oleg Zhurakousky
1ba0315460 Fix Message sanitizing logic in FunctionRSocketUtils
Only sanitize headers that are not serializable
2021-03-05 08:43:19 +01:00
Oleg Zhurakousky
e5c7452933 GH-663 Fix how strtategies are used to register additional encoders/decoders
Resolves #663
2021-03-05 08:08:16 +01:00
Oleg Zhurakousky
c67d43c30e Polish documentation 2021-03-03 08:18:19 +01:00
Oleg Zhurakousky
51aabf9aa8 Polish documentation 2021-03-03 08:17:19 +01:00
Oleg Zhurakousky
f7f61645fc Polish documentation 2021-03-03 08:01:19 +01:00
Oleg Zhurakousky
f8c60e7ab6 Polish documentation 2021-03-03 07:59:10 +01:00
Oleg Zhurakousky
2bbd34c07f Update documentation with distributed function composition 2021-03-03 07:51:30 +01:00
Oleg Zhurakousky
b8d04c2448 GH-660 Update RSocket documentation with Messaging bits 2021-03-03 07:26:51 +01:00
Oleg Zhurakousky
694d831adf GH-660 Add initial suppport for sending/receiving Messages
Resolves #660
2021-03-03 06:38:33 +01:00
Oleg Zhurakousky
3c16efc6a4 GH-654 Update routing and RSocket routing documentation with details on 'MessageRoutingCallback'
Resolves #654
2021-02-24 15:48:34 +01:00
Oleg Zhurakousky
1f43bbce28 GH-654 Remove FunctionProperties injection from MessageRoutingCallbackRSocketTests 2021-02-24 13:31:31 +01:00
Oleg Zhurakousky
410d494467 GH-654 Add more tests, cleanup and initial javadoc 2021-02-24 08:49:53 +01:00
Oleg Zhurakousky
26c11b4463 GH-654 Fix how RoutingFunction is treated by RSocketListenerFunction 2021-02-23 16:58:37 +01:00
Oleg Zhurakousky
29115aeb64 GH-654 Initial support for non-SpEL based routing mechanism 2021-02-23 06:19:45 +01:00
Oleg Zhurakousky
71c0d6d71e Fix spelling error in constant name 2021-02-22 14:11:27 +01:00
Oleg Zhurakousky
3821e5745c 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
0abce5a2b8 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
54eedc6713 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
57776c6b0c 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
7c216847b2 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
81d6998635 Add initial RSocket test with RoutingFunction 2021-02-18 14:42:14 +01:00