package org.onlab.onos.store.cluster.messaging;

import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

import org.onlab.onos.cluster.NodeId;

public interface ClusterMessageResponse extends Future<byte[]> {

    public NodeId sender();

    // TODO InterruptedException, ExecutionException removed from original
    // Future declaration. Revisit if we ever need those.
    @Override
    public byte[] get(long timeout, TimeUnit unit) throws TimeoutException;

}