import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.timeout;
import static org.mockito.Mockito.verify;
+import static org.opendaylight.controller.cluster.access.client.ConnectionEntryMatcher.entryWithRequest;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.testkit.TestProbe;
import java.util.Optional;
import java.util.function.Consumer;
-import org.hamcrest.BaseMatcher;
-import org.hamcrest.Description;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
return new AbortLocalTransactionRequest(identifier, replyTo);
}
- private static ConnectionEntryMatcher entryWithRequest(final Request<?, ?> request) {
- return new ConnectionEntryMatcher(request);
- }
-
- private static class ConnectionEntryMatcher extends BaseMatcher<ConnectionEntry> {
-
- private final Request request;
-
- private ConnectionEntryMatcher(final Request request) {
- this.request = request;
- }
-
- @Override
- public boolean matches(final Object item) {
- if (!(item instanceof ConnectionEntry)) {
- return false;
- }
- final ConnectionEntry entry = (ConnectionEntry) item;
- return this.request.equals(entry.getRequest());
- }
-
- @Override
- public void describeMismatch(final Object item, final Description description) {
- final ConnectionEntry entry = (ConnectionEntry) item;
- super.describeMismatch(entry.getRequest(), description);
- }
-
- @Override
- public void describeTo(final Description description) {
- description.appendValue(request);
- }
- }
-
-}
+}
\ No newline at end of file