DumpByResorceCacheAction.java

Go to the documentation of this file.

package org.openkilda.wfm.ctrl;

import com.fasterxml.jackson.core.JsonProcessingException;
import org.apache.storm.task.TopologyContext;
import org.openkilda.messaging.ctrl.AbstractDumpState;
import org.openkilda.messaging.ctrl.DumpStateResponseData;
import org.openkilda.wfm.error.MessageFormatException;
import org.openkilda.wfm.error.UnsupportedActionException;

import java.util.Optional;

public class DumpByResorceCacheAction extends CtrlEmbeddedAction {

    public DumpByResorceCacheAction(CtrlAction master, RouteMessage message) {
        super(master, message);
    }

    @Override
    protected void handle()
            throws MessageFormatException, UnsupportedActionException, JsonProcessingException {
        Optional<AbstractDumpState> state = getMaster().getBolt().dumpResorceCacheState();

        if (state.isPresent()) {
            TopologyContext context = getBolt().getContext();
            emitResponse(new DumpStateResponseData(context.getThisComponentId(),
                    context.getThisTaskId(), getMessage().getTopology(), state.get()));
        }
    }
}