Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.uberfire.io.impl.cluster;
 
 import java.util.Map;
 
 import  org.uberfire.commons.cluster.ClusterService;
 import  org.uberfire.commons.message.MessageType;
import  org.uberfire.java.nio.base.FileSystemId;
import  org.uberfire.java.nio.file.FileSystem;
import static org.uberfire.io.impl.cluster.ClusterMessageType.*;
public class FileSystemSyncNonLock<V> {
    private final String serviceId;
    private final String scheme;
    private final String id;
    private final String uri;
    public FileSystemSyncNonLockfinal String serviceId,
                                  final FileSystem fileSystem ) {
        this. = serviceId;
        this. = fileSystem.getRootDirectories().iterator().next().toUri().getScheme();
        this. = ( (FileSystemId) fileSystem ).id();
        this. = fileSystem.toString();
    }
    public MessageType getMessageType() {
        return ;
    }
    public String getServiceId() {
        return ;
    }
    public Map<StringStringbuildContent() {
        return new HashMap<StringString>() {{
            put"fs_scheme" );
            put"fs_id" );
            put"fs_uri" );
        }};
    }
    public void sendMessagefinal ClusterService clusterService ) {
        clusterService.broadcast( getServiceId(), getMessageType(), buildContent() );
    }
    public V executefinal ClusterService clusterService,
                      final RunnableFuture<V> task ) {
        try {
            task.run();
            final V result = task.get();
            sendMessageclusterService );
            return result;
        } catch ( final ExecutionException e ) {
            throwExceptione.getCause() );
        } catch ( final Exception e ) {
            throwExceptione );
        }
        return null;
    }
    private void throwExceptionfinal Throwable e ) {
        if ( e instanceof RuntimeException ) {
            throw (RuntimeExceptione;
        }
        throw new RuntimeExceptione );
    }
New to GrepCode? Check out our FAQ X