This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit af8375813dedd8f1d6811976e05deb2c97cc1db1 Author: Till Rohrmann <[email protected]> AuthorDate: Wed Apr 24 17:29:31 2019 +0200 [hotfix] Remove legacy DummyActorGateway --- .../flink/runtime/instance/DummyActorGateway.java | 78 ---------------------- 1 file changed, 78 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/instance/DummyActorGateway.java b/flink-runtime/src/test/java/org/apache/flink/runtime/instance/DummyActorGateway.java deleted file mode 100644 index 68e2aea..0000000 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/instance/DummyActorGateway.java +++ /dev/null @@ -1,78 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.flink.runtime.instance; - -import akka.actor.ActorRef; -import scala.concurrent.ExecutionContext; -import scala.concurrent.Future; -import scala.concurrent.duration.FiniteDuration; - -import java.util.UUID; - -/** - * Dummy {@link ActorGateway} implementation used for testing. - */ -public class DummyActorGateway implements ActorGateway { - public static final DummyActorGateway INSTANCE = new DummyActorGateway(); - private static final long serialVersionUID = -833861606769367952L; - - private final String path; - - public DummyActorGateway() { - this("DummyActorGateway"); - } - - public DummyActorGateway(String path) { - this.path = path; - } - - @Override - public Future<Object> ask(Object message, FiniteDuration timeout) { - return null; - } - - @Override - public void tell(Object message) {} - - @Override - public void tell(Object message, ActorGateway sender) {} - - @Override - public void forward(Object message, ActorGateway sender) {} - - @Override - public Future<Object> retry(Object message, int numberRetries, FiniteDuration timeout, ExecutionContext executionContext) { - return null; - } - - @Override - public String path() { - return path; - } - - @Override - public ActorRef actor() { - return ActorRef.noSender(); - } - - @Override - public UUID leaderSessionID() { - return null; - } -}
