Examples of java.io.Closeable

java.io.Closeable
Closeable represents the source or destination of some data which can be called its close method to release resources it holds.

    }


    @Test
    public void close_success() throws Exception
    {
        Closeable c = newMock(Closeable.class);


        c.close();


        replay();


        InternalUtils.close(c);

View Full Code Here

    }


    @Test
    public void close_ignores_exceptions() throws Exception
    {
        Closeable c = newMock(Closeable.class);


        c.close();
        setThrowable(new IOException());


        replay();


        InternalUtils.close(c);

View Full Code Here

                     public Integer get() {
                        int exitStatus = executor.getExitStatus();
                        return exitStatus != -1 ? exitStatus : null;
                     }


                  }, new Closeable() {


                     @Override
                     public void close() throws IOException {
                        clear();
                     }

View Full Code Here

        d.addSequence(ds, false);
        //TODO add the redelivery code
    }


    RMEndpoint createReliableEndpoint(final Endpoint endpoint) {
        endpoint.addCleanupHook(new Closeable() {
            public void close() throws IOException {
                shutdownReliableEndpoint(endpoint);
            }
        });
        return new RMEndpoint(this, endpoint);

View Full Code Here

        final VirtualFile webinfLib = deploymentRoot.getChild(WEB_INF_LIB);
        if (webinfLib.exists()) {
            final List<VirtualFile> archives = webinfLib.getChildren(DEFAULT_WEB_INF_LIB_FILTER);
            for (final VirtualFile archive : archives) {
                try {
                    final Closeable closable = VFS.mountZip(archive, archive, TempFileProviderService.provider());
                    final ResourceRoot webInfArchiveRoot = new ResourceRoot(archive.getName(), archive, new MountHandle(closable));
                    ModuleRootMarker.mark(webInfArchiveRoot);
                    entries.add(webInfArchiveRoot);
                } catch (IOException e) {
                    throw new DeploymentUnitProcessingException("failed to process " + archive, e);

View Full Code Here

     * Closes this resource and releases any system resources associated with it. If the resource is already closed,
     * then invoking this method has no effect.  In addition, if the resource has already been garbage collected, this
     * operation has no effect.
     */
    public void close() throws IOException {
        final Closeable closeable = resource.get();
        if (closeable != null) {
            closeable.close();
        }
    }

View Full Code Here

            if (!libDirName.isEmpty()) {
                libDir = virtualFile.getChild(libDirName);
                if (libDir.exists()) {
                    List<VirtualFile> libArchives = libDir.getChildren(CHILD_ARCHIVE_FILTER);
                    for (final VirtualFile child : libArchives) {
                        final Closeable closable = child.isFile() ? mount(child, false) : null;
                        final MountHandle mountHandle = new MountHandle(closable);
                        final ResourceRoot childResource = new ResourceRoot(child, mountHandle);
                        if (child.getName().toLowerCase().endsWith(JAR_EXTENSION)) {
                            ModuleRootMarker.mark(childResource);
                            deploymentUnit.addToAttachmentList(Attachments.RESOURCE_ROOTS, childResource);

View Full Code Here

     * @return Returns the created {@link ResourceRoot}
     * @throws IOException
     */
    private ResourceRoot createResourceRoot(final DeploymentUnit deploymentUnit, final VirtualFile file, final boolean markAsSubDeployment, final boolean explodeDuringMount) throws IOException {
        final boolean war = file.getName().toLowerCase(Locale.ENGLISH).endsWith(WAR_EXTENSION);
        final Closeable closable = file.isFile() ? mount(file, explodeDuringMount) : null;
        final MountHandle mountHandle = new MountHandle(closable);
        final ResourceRoot resourceRoot = new ResourceRoot(file, mountHandle);
        deploymentUnit.addToAttachmentList(Attachments.RESOURCE_ROOTS, resourceRoot);
        if (markAsSubDeployment) {
            SubDeploymentMarker.mark(resourceRoot);

View Full Code Here

        }
        return null;
    }


    public Connection register(final Connection connection) {
        resources.addFirst(new Closeable() {
            
            @Override
            public void close() throws IOException {
                try {
                    connection.close();

View Full Code Here

        });
        return connection;
    }


    public Statement register(final Statement statement) {
        resources.addFirst(new Closeable() {
            
            @Override
            public void close() throws IOException {
                try {
                    statement.close();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of java.io.Closeable

au.edu.mq.comp.common.SimpleFileIO

be.frma.langguess.IOUtilsTest

com.alibaba.json.bvt.parser.IOUtilsTest

com.alibaba.jstorm.daemon.nimbus.NimbusUtils

com.carrotsearch.randomizedtesting.RandomizedTest

com.cloudera.oryx.common.io.ClosingRunnableTest

com.cloudera.oryx.common.lang.JVMUtilsTest

com.google.common.io.Closer

com.google.common.jimfs.JimfsFileSystem

com.lambdaworks.redis.AbstractRedisClient

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.