/* (non-Javadoc)
@see javax.jms.MessageProducer#close()
553507
@Override
	public final void close() throws JMSException
    {
    	externalAccessLock.readLock().lock();
    	try
		{
	        if (closed)
	            return;
	        closed = true;
	        onProducerClose();
	    }
    	finally
    	{
    		externalAccessLock.readLock().unlock();
    	}
    }
814405
public void close()
    {
        super.close();  // Do any inherrited
        try   {
            if (m_JDBCConnection != null)
                m_JDBCConnection.close();
        } catch (SQLException ex) {
                // Ignore error
        }
        m_JDBCConnection = null;
    }
680735
@Override
    public void close() {
        closeComponent(this.containerManager);
        closeComponent(this.containerRegistry);
        closeComponent(this.dataLogFactory);
        closeComponent(this.readIndexFactory);
        closeComponent(this.cacheFactory);
        this.cacheManager.close();
        this.threadPoolMetrics.close();
        ExecutorServiceHelpers.shutdown(SHUTDOWN_TIMEOUT, this.storageExecutor, this.coreExecutor);
    }
377309
@Override
  public void close() throws IOException {
    try {
      this.unlock();
    } catch (JobLockException e) {
      throw new IOException(e);
    } finally {
      lockEventListeners.remove(this.lockPath);
    }
  }
775380
@Override
    public void close() {
        if (this.inputStream != null) {
            try {
                this.inputStream.close();
            } catch (final IOException e) {
                // Ignore
            }
            this.inputStream = null;
        }
        this.byteBuffer = null;
        this.buf = null;
    }
557242
public void close() {

        if (this.xaConnection != null) {
            this.xaConnection.doClose();
        }
        this.closed = true;
        this.notifyClosed();

        if (LOG.isDebugEnabled()) {
            LOG.debug("PhynixxXAResource[" + this.getId() + "]:closed ");
        }
    }
21446
public void close() {
        if (closed.compareAndSet(false, true)) {
            synchronized (meterMapLock) {
                for (Meter meter : meterMap.values()) {
                    meter.close();
                }
            }
        }
    }
1342138
@Override
  public void close()
      throws IOException {
    if (delegateReader != null) {
      logger.atWarning().log(
          "Got non-null delegateReader during close(); possible premature close() call.");
      delegateReader.close();
      delegateReader = null;
    }
  }
953002
@Override
  public void close() {
    stopWatch.stop();

    if (logger.isLoggable(logLevel)) {
      final StringBuilder sb = new StringBuilder();
      log(sb.append(EXIT_PREFIX).append(msg).append(DURATION).append(stopWatch.getTime()).toString());
    }
  }
1041121
@Override
  public synchronized void close() throws IOException {
    if (opened) {
      face.removeRegisteredPrefix(registrationId);
      contentStore.clear();
      announcementService.announceExit(publisherId);
    }
  }
1314486
@Override
  public void close() throws IOException {
    shuttingDown = true;
    IOUtils.cleanup(null, executor);
    closeNamenodeRPC();
  }
641697
@Override
  public void close() {
    if (closed) return;
    
    closed = true;
    
    try {
      selector.close();
    } catch (Exception e) {
      logger.log("Failed to close multicast publisher selctor for: '" + name + "'", e);
    }
    
    try {
      publisherChannel.close();
    } catch (Exception e) {
      logger.log("Failed to close multicast publisher channel for: '" + name + "'", e);
    }
    
    try {
      readChannel.close();
    } catch (Exception e) {
      logger.log("Failed to close multicast reader channel for: '" + name + "'", e);
    }
  }
1275723
protected final void closeConnection(final JsMessagingEngine messagingEngine) {

        final String methodName = "closeConnection";
        if (TraceComponent.isAnyTracingEnabled() && TRACE.isEntryEnabled()) {
            SibTr.entry(this, TRACE, methodName, messagingEngine);
        }

        closeConnection(messagingEngine.getUuid().toString());

        if (TraceComponent.isAnyTracingEnabled() && TRACE.isEntryEnabled()) {
            SibTr.exit(this, TRACE, methodName);
        }

    }
162784
public void close() {
        try {
            synchronized (lock) {
                if (out == null)
                    return;
                out.close();
                out = null;
            }
        }
        catch (IOException x) {
            trouble = true;
        }
    }
89049
@Override
  public final void close() {
    try {
      doClose();
      isClosed = true;
    } catch (Exception e) {
      Throwables.propagate(e);
    }
  }
355661
private void _close()
      throws SIResourceException, SIConnectionLostException, SIErrorException,
             SIConnectionDroppedException
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "_close");

      CommsByteBuffer request = getCommsByteBuffer();

      // Build Message Header
      request.putShort(getConnectionObjectID());
      request.putShort(getProxyID());

      // Pass on call to server
      CommsByteBuffer reply = jfapExchange(request,
                                           JFapChannelConstants.SEG_CLOSE_CONSUMER_SESS,
                                           JFapChannelConstants.PRIORITY_MEDIUM,
                                           true);

      try
      {
         short err = reply.getCommandCompletionCode(JFapChannelConstants.SEG_CLOSE_CONSUMER_SESS_R);
         if (err != CommsConstants.SI_NO_EXCEPTION)
         {
            checkFor_SIConnectionDroppedException(reply, err);
            checkFor_SIResourceException(reply, err);
            checkFor_SIConnectionLostException(reply, err);
            checkFor_SIErrorException(reply, err);
            defaultChecker(reply, err);
         }
      }
      finally
      {
         if (reply != null) reply.release();
      }

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "_close");
   }
1089274
public void closeProducersDestinationDeleted()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "closeProducersDestinationDeleted");

    synchronized (_producers)
    {
      _destinationDeleted = true;

      Iterator<MessageProducer> i = _producers.iterator();

      while(i.hasNext())
      {
        ProducerSessionImpl producerSessionImpl = (ProducerSessionImpl) i.next();

          // Close the producer session, indicating that it has been closed due to delete
          producerSessionImpl._closeProducerDestinationDeleted();

          // Remove the producer session from the Producers ArrayList
          i.remove();        
      }
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "closeProducersDestinationDeleted");
  }