GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2358
[FLINK-4382] Buffer rpc calls until the RpcEndpoint has been started
This PR allows the AkkaRpcActor to stash messages until the corresponding
RcpEndpoint
has been started. When receiving a Processing.START message, the
AkkaRpcActor
unstashes all messages and starts processing rpcs. When receiving a
Processing.STOP
message, it will stop processing messages and stash incoming messages again.
This PR is based on #2357.
R @StephanEwen
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink messageStashing
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2358.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2358
----
commit 13f6f392943e32b14bf0d08c7ded2d88496911ab
Author: Till Rohrmann <[email protected]>
Date: 2016-08-10T16:42:26Z
[FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies
This PR introduces a generic AkkaRpcActor which receives rpc calls as a
RpcInvocation message. The RpcInvocation message is generated by the
AkkaInvocationHandler which gets them from automatically generated Java
Proxies.
Add documentation for proxy based akka rpc service
commit 32dbb077e49c8d6180afaaf844238fd6a3178395
Author: Till Rohrmann <[email protected]>
Date: 2016-08-11T15:27:18Z
Log unknown message type in AkkaRpcActor but do not fail actor
commit 2c8062fb5ad567932bb63a9c005587773e0f0ab9
Author: Till Rohrmann <[email protected]>
Date: 2016-08-11T16:13:25Z
[FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started
This PR allows the AkkaRpcActor to stash messages until the corresponding
RcpEndpoint
has been started. When receiving a Processing.START message, the
AkkaRpcActor
unstashes all messages and starts processing rpcs. When receiving a
Processing.STOP
message, it will stop processing messages and stash incoming messages again.
commit 3477f1d819d4a30d1fe73d0689117acfc63c8534
Author: Till Rohrmann <[email protected]>
Date: 2016-08-11T16:35:03Z
Add test case for message stashing
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
