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
buildmaster
315ed4612d
Bumping versions
2021-02-01 18:56:47 +00:00
buildmaster
06872f573a
Bumping versions
2021-01-27 18:56:44 +00:00
buildmaster
043668db4b
Bumping versions to 3.1.2-SNAPSHOT after release
2021-01-27 17:16:38 +00:00
buildmaster
0b8d00b1df
Going back to snapshots
2021-01-27 17:16:37 +00:00
buildmaster
ea03395bb3
Update SNAPSHOT to 3.1.1
2021-01-27 17:11:29 +00:00
Oleg Zhurakousky
a6cb0fde3c
Fix RSocket CloudEvents sample
2021-01-27 15:29:16 +01:00
Oleg Zhurakousky
b28087d6a3
Revert "Bumping versions"
...
This reverts commit cbd0bee65f .
2021-01-14 12:36:38 +01:00
buildmaster
cbd0bee65f
Bumping versions
2021-01-13 18:56:32 +00:00
Oleg Zhurakousky
5894433ed5
Revert "Bumping versions"
...
This reverts commit 6a3bde7d64 .
2021-01-11 10:44:04 +01:00
buildmaster
6a3bde7d64
Bumping versions
2020-12-21 18:56:08 +00:00
Oleg Zhurakousky
1f1ba66764
Fix snapshot versions
2020-12-21 18:04:32 +01:00
buildmaster
2f933b9b01
Bumping versions to 3.1.1.SNAPSHOT after release
2020-12-21 11:57:51 +00:00
buildmaster
45161d683d
Going back to snapshots
2020-12-21 11:57:50 +00:00
buildmaster
3a0ed3941f
Update SNAPSHOT to 3.1.0
2020-12-21 11:54:46 +00:00
Oleg Zhurakousky
e3b5e2b0cb
GH-590 change README extension
2020-12-21 10:28:21 +01:00
Oleg Zhurakousky
ab59776fb5
GH-590 Add initial RSocket documentation
2020-12-21 10:26:55 +01:00
Oleg Zhurakousky
bc4b5b3f80
Add stream (kafka, Rabbit) and Rsocket examples for Cloud Event
2020-12-18 16:44:29 +01:00