Commit Graph

27 Commits

Author SHA1 Message Date
Oleg Zhurakousky
3b26ca1282 Revert "Temporarily disable rsocket-routing-broker integration"
This reverts commit c3d6b48e92.
2020-09-23 17:12:46 +02:00
Oleg Zhurakousky
c3d6b48e92 Temporarily disable rsocket-routing-broker integration 2020-09-23 16:24:01 +02:00
Oleg Zhurakousky
6c6f98fa1d Re-enable routing broker tests after fixes in routing broker 2020-09-17 11:43:54 +02:00
Oleg Zhurakousky
d3afd1fea4 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
584d238b9e Remove dead code from FunctionRSocketMessageHandler
Add and clean up tests
2020-09-02 08:27:51 +02:00
Oleg Zhurakousky
b053761be7 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
f0ad6bf8ac Updates to new routing client broker tcp properties 2020-08-31 19:14:58 -04:00
Spencer Gibb
87187692ae 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
8801efa445 Temporary disabling of RoutingBrokerTests 2020-08-28 09:16:05 +02:00
Oleg Zhurakousky
353fd2e8d0 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
e4c999b3ea Updates property based metadata to use uppercase function name 2020-08-27 13:51:21 -04:00
Oleg Zhurakousky
b681fb96d6 Cherry-pick type of merge the work from Artem in #580
Resolves #580
2020-08-27 14:34:24 +02:00
Oleg Zhurakousky
2607cfc34b Formatting test code 2020-08-26 15:23:31 +02:00
Oleg Zhurakousky
9a1827d291 Ad initial support for propagating metadata as Message headers 2020-08-26 15:19:23 +02:00
Oleg Zhurakousky
91661c3887 Add RSocketRequester configuration for tests 2020-08-26 14:35:34 +02:00
Oleg Zhurakousky
0640de87dd Remove custom server creation logic and rely on boot instead
Resolves #579
2020-08-26 10:03:11 +02:00
Oleg Zhurakousky
78de449d25 Polish RoutingBrokerTests 2020-08-25 21:20:11 +02:00
spencergibb
87f71a55e5 Uses renamed RoutingMetadata 2020-08-25 14:17:36 -04:00
spencergibb
21ce6ed517 Comment out SpringRouting 2020-08-25 12:16:34 -04:00
spencergibb
a0940a4863 Uses property based routing client request metadata 2020-08-25 12:14:01 -04:00
spencergibb
db28b7efdc Migrates to using rsocket-routing-broker 2020-08-24 15:49:31 -04:00
spencergibb
311d67c38b Initial rsocket-broker sample 2020-08-24 15:22:52 -04:00
Oleg Zhurakousky
cde6535d70 interim 2020-07-16 17:08:55 +02:00
Oleg Zhurakousky
bc7376f2a6 Cleanup 'requestChannel' logic
Add RSocketConnectionUtils to deal with connectivity logic
2020-07-16 15:58:22 +02:00
Oleg Zhurakousky
f725b5aeb8 Add StepVerifier to RSocket tests 2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
76dde19b89 Add initial support for 'requestChannel' intergration for RSocket 2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
c91e2a00e4 Initial Committ of RSocket integration 2020-07-16 13:35:21 +02:00