Sha256: 4253aabbdb776e95c27b3430855088a68724d32b6274126b0967fca0c4abd354
Contents?: true
Size: 661 Bytes
Versions: 6
Compression:
Stored size: 661 Bytes
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 ServerSessionRegistry sessionRegistry;
RemoveSessionCommand(ServerSessionRegistry sessionRegistry) {
this.sessionRegistry = sessionRegistry;
}
@Override
public Void apply(String sessionId, Connection connection) {
sessionRegistry.remove(sessionId);
return null;
}
@Override
public String getId() {
return ID;
}
}
Version data entries
6 entries across 6 versions & 1 rubygems