Contents

package org.embulk.executor.remoteserver;

import com.github.kamatama41.nsocket.Connection;
import com.github.kamatama41.nsocket.SyncCommand;

public class RemoveSessionCommand implements SyncCommand<String, Void> {
    static final String ID = "remove_session";
    private final SessionManager sessionManager;

    RemoveSessionCommand(SessionManager sessionManager) {
        this.sessionManager = sessionManager;
    }

    @Override
    public Void apply(String sessionId, Connection connection) {
        sessionManager.removeSession(sessionId);
        return null;
    }

    @Override
    public String getId() {
        return ID;
    }
}

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
embulk-executor-remoteserver-0.1.1	src/main/java/org/embulk/executor/remoteserver/RemoveSessionCommand.java
embulk-executor-remoteserver-0.1.0	src/main/java/org/embulk/executor/remoteserver/RemoveSessionCommand.java