Orbit Code

ORBIT : Operating Business Intelligence Tool

Status: Beta

Brought to you by: orbitapp

Commit [e2aeab] v2.0.0-alpha.74 Maximize Restore History

Reroute messages on deactivation (#431)

* Initial implementation for a RerouteMessageException option for bouncing messages back into the system when an addressable has been deactivated during shutdown.

* Remove one reference to container in invocation system code.

* Add a not-quite working integration test around rerouting messages.

* Add invocation reason concept to support rerouting messages, add unit testing to Addressable Manager, allow avoiding invalid nodes in placement.

* Couple bits of cleanup in server code.

* Include Invocation Reason in messages bounced during client actor deactivation.

* Add reroute invocation reason to bounced client messages, fix failing deactivate test for new behavior, minor fixes.

* Fix for incorrectly replaced expiration check in addressable manager, more unit tests around abandoning lease.

* Couple test adjustments.

* Possible good fix for server tests.

* Broaden timing test criteria.

* Bump Mockito version hoping that helps with tests, suspend tweak.

* Revert "Bump Mockito version hoping that helps with tests, suspend tweak."

This reverts commit e5ef0656bb5656bee91d1595cc847d9e6dbe61a8.

* Adjusting Metric test, enable info build output, fix some base test suspending.

* Leave a little time advancement in metric test.

* Fix base client test suspending.

* Remove log info from build output

* Remove a TODO and vestigial println

* Little more cleanup.

* Quick empty list optimization

Co-authored-by: Brett Morien <bmorien@...>

Authored by: Brett Morien 2020-06-23

Committed by: GitHub GitHub 2020-06-23

Browse code at this revision

Parent: [8eb049]

Child: [e0fe83]

changed	build.gradle.kts
changed	src/orbit-client/src/main/kotlin/orbit/client/addressable/InvocationSystem.kt
changed	src/orbit-client/src/main/kotlin/orbit/client/execution/ExecutionHandle.kt
changed	src/orbit-client/src/main/kotlin/orbit/client/execution/ExecutionSystem.kt
changed	src/orbit-client/src/main/kotlin/orbit/client/net/ConnectionHandler.kt
changed	src/orbit-client/src/test/kotlin/orbit/client/BaseIntegrationTest.kt
changed	src/orbit-client/src/test/kotlin/orbit/client/DeactivationTests.kt
changed	src/orbit-client/src/test/kotlin/orbit/client/actor/TestActors.kt
added	src/orbit-client/src/test/kotlin/orbit/client/alternativeActor/TestActors.kt
changed	src/orbit-proto/src/main/kotlin/orbit/shared/proto/MessageConverters.kt
changed	src/orbit-proto/src/main/proto/orbit/shared/messages.proto
changed	src/orbit-proto/src/test/kotlin/orbit/shared/proto/MessagesTest.kt
changed	src/orbit-server/src/main/kotlin/orbit/server/mesh/AddressableManager.kt
changed	src/orbit-server/src/main/kotlin/orbit/server/pipeline/step/PlacementStep.kt
added	src/orbit-server/src/test/kotlin/orbit/server/AddressableManagerTests.kt
changed	src/orbit-server/src/test/kotlin/orbit/server/BaseServerTest.kt
changed	src/orbit-server/src/test/kotlin/orbit/server/MetricsTests.kt
changed	src/orbit-shared/src/main/kotlin/orbit/shared/addressable/Addressable.kt
changed	src/orbit-shared/src/main/kotlin/orbit/shared/exception/Exception.kt
changed	src/orbit-shared/src/main/kotlin/orbit/shared/net/Message.kt
changed	src/orbit-util/src/main/kotlin/orbit/util/time/Clock.kt
changed	src/orbit-util/src/test/kotlin/orbit/util/misc/HighResolutionTickerTest.kt

Orbit Code

ORBIT : Operating Business Intelligence Tool

Branches

Tags

Commit [e2aeab] v2.0.0-alpha.74 Maximize Restore History

build.gradle.kts Diff Switch to side-by-side view

src/orbit-client/src/main/kotlin/orbit/client/addressable/InvocationSystem.kt Diff Switch to side-by-side view

src/orbit-client/src/main/kotlin/orbit/client/execution/ExecutionHandle.kt Diff Switch to side-by-side view

src/orbit-client/src/main/kotlin/orbit/client/execution/ExecutionSystem.kt Diff Switch to side-by-side view

src/orbit-client/src/main/kotlin/orbit/client/net/ConnectionHandler.kt Diff Switch to side-by-side view

src/orbit-client/src/test/kotlin/orbit/client/BaseIntegrationTest.kt Diff Switch to side-by-side view

src/orbit-client/src/test/kotlin/orbit/client/DeactivationTests.kt Diff Switch to side-by-side view

src/orbit-client/src/test/kotlin/orbit/client/actor/TestActors.kt Diff Switch to side-by-side view

src/orbit-client/src/test/kotlin/orbit/client/alternativeActor/TestActors.kt Diff Switch to side-by-side view

src/orbit-proto/src/main/kotlin/orbit/shared/proto/MessageConverters.kt Diff Switch to side-by-side view

src/orbit-proto/src/main/proto/orbit/shared/messages.proto Diff Switch to side-by-side view

src/orbit-proto/src/test/kotlin/orbit/shared/proto/MessagesTest.kt Diff Switch to side-by-side view

src/orbit-server/src/main/kotlin/orbit/server/mesh/AddressableManager.kt Diff Switch to side-by-side view

src/orbit-server/src/main/kotlin/orbit/server/pipeline/step/PlacementStep.kt Diff Switch to side-by-side view

src/orbit-server/src/test/kotlin/orbit/server/AddressableManagerTests.kt Diff Switch to side-by-side view

src/orbit-server/src/test/kotlin/orbit/server/BaseServerTest.kt Diff Switch to side-by-side view

src/orbit-server/src/test/kotlin/orbit/server/MetricsTests.kt Diff Switch to side-by-side view

src/orbit-shared/src/main/kotlin/orbit/shared/addressable/Addressable.kt Diff Switch to side-by-side view

src/orbit-shared/src/main/kotlin/orbit/shared/exception/Exception.kt Diff Switch to side-by-side view

src/orbit-shared/src/main/kotlin/orbit/shared/net/Message.kt Diff Switch to side-by-side view

src/orbit-util/src/main/kotlin/orbit/util/time/Clock.kt Diff Switch to side-by-side view

src/orbit-util/src/test/kotlin/orbit/util/misc/HighResolutionTickerTest.kt Diff Switch to side-by-side view