src/main/java/pl/edu/mimuw/cloudatlas/agent/messages/RequestStateMessage.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

package pl.edu.mimuw.cloudatlas.agent.messages;

import java.util.concurrent.CompletableFuture;

public class RequestStateMessage extends RemikMessage {
    CompletableFuture<ResponseMessage> responseFuture;

    public RequestStateMessage(String messageId, long timestamp, CompletableFuture<ResponseMessage> responseFuture) {
        super(messageId, timestamp, Type.REQUEST_STATE);
        this.responseFuture = responseFuture;
    }

    public RequestStateMessage() {}

    public CompletableFuture<ResponseMessage> getFuture() {
        return responseFuture;
    }
}