[Networking Add ability to register raw handlers in message router

[AhmedSoliman]

[Networking Add ability to register raw handlers in message router

Also, this introduces a mechanism to subscribe to connection closed events via ConnectionSender

---

Stack created with Sapling. Best reviewed with ReviewStack.

• [ReplicatedLoglet] ReplicationProperty is failure-domain-aware #1959
• -> [Networking Add ability to register raw handlers in message router #1957

[github-actions]

Test Results

15 files  +10  15 suites  +10   21m 36s ⏱️ + 19m 20s
 6 tests  - 36   6 ✅  - 36  0 💤 ±0  0 ❌ ±0 
18 runs   - 86  18 ✅  - 86  0 💤 ±0  0 ❌ ±0 

Results for commit 8eda441. ± Comparison against base commit eb5e849.

This pull request removes 42 and adds 6 tests. Note that renamed tests count towards both.

dev.restate.sdktesting.tests.AwaitTimeout ‑ timeout(Client)
dev.restate.sdktesting.tests.CallOrdering ‑ ordering(boolean[], Client)[1]
dev.restate.sdktesting.tests.CallOrdering ‑ ordering(boolean[], Client)[2]
dev.restate.sdktesting.tests.CallOrdering ‑ ordering(boolean[], Client)[3]
dev.restate.sdktesting.tests.CancelInvocation ‑ cancelInvocation(BlockingOperation, Client, URL)[1]
dev.restate.sdktesting.tests.CancelInvocation ‑ cancelInvocation(BlockingOperation, Client, URL)[2]
dev.restate.sdktesting.tests.CancelInvocation ‑ cancelInvocation(BlockingOperation, Client, URL)[3]
dev.restate.sdktesting.tests.Ingress ‑ headersPassThrough(Client)
dev.restate.sdktesting.tests.Ingress ‑ idempotentInvokeSend(Client)
dev.restate.sdktesting.tests.Ingress ‑ idempotentInvokeService(Client)
…

dev.restate.e2e.JavaAwakeableTest ‑ generate(Client)
dev.restate.e2e.KtInterpreterTest ‑ simple(int)
dev.restate.e2e.NodeAwakeableTest ‑ generate(Client)
dev.restate.e2e.NodeInterpreterTest ‑ simple(int)
dev.restate.e2e.RetryOnUnknownServiceTest ‑ retryOnUnknownServiceUsingCall(Client, URL)
dev.restate.e2e.RetryOnUnknownServiceTest ‑ retryOnUnknownServiceUsingOneWayCall(Client, URL)

♻️ This comment has been updated with latest results.