X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Feos-dom-akka%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Feos%2Fakka%2Fowner%2Fsupervisor%2Fcommand%2FGetEntitiesBackendReply.java;fp=opendaylight%2Fmd-sal%2Feos-dom-akka%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Feos%2Fakka%2Fowner%2Fsupervisor%2Fcommand%2FGetEntitiesBackendReply.java;h=beb858c8df3d7b7f1f5b590c33c6069aec7b152e;hb=1adec580405aafae353f8b0b3a5a0f474a05c6c0;hp=0000000000000000000000000000000000000000;hpb=f2868cf8e1ddc85ec1128199ed2607922ea74c24;p=controller.git diff --git a/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/owner/supervisor/command/GetEntitiesBackendReply.java b/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/owner/supervisor/command/GetEntitiesBackendReply.java new file mode 100644 index 0000000000..beb858c8df --- /dev/null +++ b/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/owner/supervisor/command/GetEntitiesBackendReply.java @@ -0,0 +1,39 @@ +/* + * Copyright (c) 2021 PANTHEON.tech, s.r.o. and others. All rights reserved. + * + * This program and the accompanying materials are made available under the + * terms of the Eclipse Public License v1.0 which accompanies this distribution, + * and is available at http://www.eclipse.org/legal/epl-v10.html + */ +package org.opendaylight.controller.eos.akka.owner.supervisor.command; + +import com.google.common.collect.ImmutableMap; +import com.google.common.collect.ImmutableSetMultimap; +import java.io.Serializable; +import java.util.Map; +import java.util.Set; +import org.opendaylight.mdsal.eos.dom.api.DOMEntity; + +public final class GetEntitiesBackendReply extends OwnerSupervisorReply implements Serializable { + private static final long serialVersionUID = 1L; + + private final ImmutableSetMultimap candidates; + private final ImmutableMap owners; + + public GetEntitiesBackendReply(final Map owners, final Map> candidates) { + final ImmutableSetMultimap.Builder builder = ImmutableSetMultimap.builder(); + for (Map.Entry> entry : candidates.entrySet()) { + builder.putAll(entry.getKey(), entry.getValue()); + } + this.candidates = builder.build(); + this.owners = ImmutableMap.copyOf(owners); + } + + public ImmutableSetMultimap getCandidates() { + return candidates; + } + + public ImmutableMap getOwners() { + return owners; + } +}