- protected short getRemoteTransactionVersion() {
- return remoteTransactionVersion;
- }
-
- protected Future<Object> executeOperationAsync(SerializableMessage msg) {
- return completeOperation(actorContext.executeOperationAsync(getActor(), msg.toSerializable()));
+ protected Future<Object> executeOperationAsync(SerializableMessage msg, Timeout timeout) {
+ return completeOperation(actorContext.executeOperationAsync(getActor(), msg.toSerializable(), timeout));