javax.resource.spi.ConnectionEvent.getSource()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(91)

本文整理了Java中javax.resource.spi.ConnectionEvent.getSource()方法的一些代码示例，展示了ConnectionEvent.getSource()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ConnectionEvent.getSource()方法的具体详情如下：
包路径：javax.resource.spi.ConnectionEvent
类名称：ConnectionEvent
方法名：getSource

ConnectionEvent.getSource介绍

暂无

代码示例

代码示例来源：origin: apache/geode

/**
 * Callback for Connection Closed.
 *
 * @param event ConnectionEvent Object.
 */
@Override
public void connectionClosed(ConnectionEvent event) {
 if (isActive) {
  ManagedConnection conn = (ManagedConnection) event.getSource();
  XAResource xar = null;
  if (xaResourcesMap.get(conn) != null)
   xar = (XAResource) xaResourcesMap.get(conn);
  xaResourcesMap.remove(conn);
  try {
   Transaction txn = transManager.getTransaction();
   if (txn != null && xar != null) {
    txn.delistResource(xar, XAResource.TMSUCCESS);
   }
  } catch (Exception se) {
   String exception =
     "JCAConnectionManagerImpl::connectionClosed: Exception occurred due to " + se;
   if (logger.isDebugEnabled()) {
    logger.debug(exception, se);
   }
  }
  mannPoolCache.returnPooledConnectionToPool(conn);
 }
}

代码示例来源：origin: apache/geode

/**
 * Callback for Connection Closed.
 *
 * @param event ConnectionEvent Object.
 */
@Override
public void connectionClosed(ConnectionEvent event) {
 if (isActive) {
  ManagedConnection conn = (ManagedConnection) event.getSource();
  TransactionManagerImpl transManager = TransactionManagerImpl.getTransactionManager();
  try {
   Transaction txn = transManager.getTransaction();
   if (txn == null) {
    mannPoolCache.returnPooledConnectionToPool(conn);
   }
  } catch (Exception se) {
   String exception =
     "FacetsJCAConnectionManagerImpl::connectionClosed: Exception occurred due to "
       + se.getMessage();
   if (logger.isDebugEnabled()) {
    logger.debug(exception, se);
   }
  }
 }
}

代码示例来源：origin: apache/geode

if (isActive) {
 ManagedConnection conn = (ManagedConnection) event.getSource();

代码示例来源：origin: apache/geode

if (isActive) {
 ManagedConnection conn = (ManagedConnection) event.getSource();
 XAResource xar = (XAResource) xaResourcesMap.get(conn);
 xaResourcesMap.remove(conn);

代码示例来源：origin: apache/cxf

public void connectionClosed(ConnectionEvent event) {
  try {
    ((ManagedConnection)event.getSource()).destroy();
  } catch (ResourceException e) {
    LOG.log(Level.SEVERE, "Failed to destroy connection.", e);
  }
}

代码示例来源：origin: apache/cxf

public void connectionErrorOccurred(ConnectionEvent event) {
  try {
    ((ManagedConnection)event.getSource()).destroy();
  } catch (ResourceException e) {
    LOG.log(Level.SEVERE, "Failed to destroy connection.", e);
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

public void connectionClosed(ConnectionEvent evt) {
  ManagedConnection mc = (ManagedConnection) evt.getSource();
  try {
    mc.destroy();
  } catch (Throwable re) {
    if (_logger.isLoggable(Level.FINE)) {
      _logger.fine("error while destroying Unpooled Managed Connection");
    }
  }
  if (_logger.isLoggable(Level.FINE)) {
    _logger.fine("UnpooledConnectionEventListener: Connection closed");
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

/**
 * Resource adapters will signal that the connection being closed is bad.
 * @param evt ConnectionEvent
 */
public void badConnectionClosed(ConnectionEvent evt){
  ManagedConnection mc = (ManagedConnection) evt.getSource();
  mc.removeConnectionEventListener(this);
  connectionClosed(evt);
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

/**
 * Resource adapters will signal that the connection being closed is bad.
 *
 * @param evt ConnectionEvent
 */
public void badConnectionClosed(ConnectionEvent evt) {
  ManagedConnection mc = (ManagedConnection) evt.getSource();
  mc.removeConnectionEventListener(this);
  poolMgr.badResourceClosed(resource);
}

代码示例来源：origin: org.firebirdsql.jdbc/jaybird-jdk17

/**
 * <code>javax.resource.spi.ConnectionEventListener</code> callback for 
 * when a <code>ManagedConnection</code> is closed.
 *
 * @param ce contains information about the connection that has be closed
 */
public void connectionClosed(ConnectionEvent ce) {
  try {
    ((FBManagedConnection)ce.getSource()).destroy();
  }
  catch (ResourceException e) {
    if (log!=null) log.debug("Exception closing unmanaged connection: ", e);
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

/**
 * Resource adapters will signal that the connection being closed is bad.
 * @param evt ConnectionEvent
 */
public void badConnectionClosed(ConnectionEvent evt){
  Object connectionHandle = evt.getConnectionHandle();
  ResourceHandle handle = resource;
  if (associatedHandles.containsKey(connectionHandle)) {
    handle = (ResourceHandle) associatedHandles.get(connectionHandle);
  }
  ManagedConnection mc = (ManagedConnection) evt.getSource();
  mc.removeConnectionEventListener(this);
  poolMgr.badResourceClosed(handle); 
}

代码示例来源：origin: org.firebirdsql.jdbc/jaybird-jdk18

/**
 * <code>javax.resource.spi.ConnectionEventListener</code> callback for 
 * when a <code>ManagedConnection</code> is closed.
 *
 * @param ce contains information about the connection that has be closed
 */
public void connectionClosed(ConnectionEvent ce) {
  try {
    ((FBManagedConnection)ce.getSource()).destroy();
  }
  catch (ResourceException e) {
    if (log!=null) log.debug("Exception closing unmanaged connection: ", e);
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

/**
 * Resource adapters will signal that the connection is being aborted.
 *
 * @param evt ConnectionEvent
 */
public void connectionAbortOccurred(ConnectionEvent evt) {
  resource.setConnectionErrorOccurred();
  ManagedConnection mc = (ManagedConnection) evt.getSource();
  mc.removeConnectionEventListener(this);
  poolMgr.resourceAbortOccurred(resource);
}

代码示例来源：origin: org.seasar.jca/s2jca

public void connectionErrorOccurred(final ConnectionEvent event) {
  try {
    final ManagedConnection mc = (ManagedConnection) event.getSource();
    logger.log("EJCA1005", new Object[] { mc });
    policy.connectionErrorOccurred(mc);
  } catch (final Exception e) {
    logger.log("EJCA0000", null, e);
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

public void connectionErrorOccurred(ConnectionEvent evt) {
    resource.setConnectionErrorOccurred();
    ManagedConnection mc = (ManagedConnection) evt.getSource();
    mc.removeConnectionEventListener(this);
    poolMgr.resourceErrorOccurred( resource );
/*
    try {
      mc.destroy();
    } catch (Exception ex) {
      // ignore exception
    }
*/
  }

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

public void connectionErrorOccurred(ConnectionEvent evt) {
      resource.setConnectionErrorOccurred();

      ManagedConnection mc = (ManagedConnection) evt.getSource();
      mc.removeConnectionEventListener(this);
      poolMgr.resourceErrorOccurred(resource);
/*
      try {
        mc.destroy();
      } catch (Exception ex) {
        // ignore exception
      }
*/
    }

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

public void connectionErrorOccurred(ConnectionEvent evt) {
      ManagedConnection mc = (ManagedConnection) evt.getSource();
      mc.removeConnectionEventListener(this);
      poolMgr.putbackResourceToPool(resource, true);
/*
      try {
        mc.destroy();
      } catch (Exception ex) {
        // ignore exception
      }
*/
      //GJCINT
      resource.setConnectionErrorOccurred();
    }

代码示例来源：origin: org.apache.geronimo.components/geronimo-connector

public void connectionErrorOccurred(ConnectionEvent connectionEvent) {
  if (connectionEvent.getSource() != managedConnectionInfo.getManagedConnection()) {
    throw new IllegalArgumentException(
        "ConnectionError event received from wrong ManagedConnection. Expected "
        + managedConnectionInfo.getManagedConnection()
        + ", actual "
        + connectionEvent.getSource());
  }
  log.warn("connectionErrorOccurred called with " + connectionEvent.getConnectionHandle(), connectionEvent.getException());
  boolean errorOccurred = this.errorOccurred;
  this.errorOccurred = true;
  if (!errorOccurred) {
    ConnectionInfo ci = new ConnectionInfo(managedConnectionInfo);
    ci.setConnectionHandle(connectionEvent.getConnectionHandle());
    stack.returnConnection(ci, ConnectionReturnAction.DESTROY);
  }
}

代码示例来源：origin: org.seasar.jca/s2jca

public void connectionClosed(final ConnectionEvent event) {
  try {
    final ManagedConnection mc = (ManagedConnection) event.getSource();
    if (logger.isDebugEnabled()) {
      logger.log("DJCA1002", new Object[] { mc });
    }
    policy.release(mc);
  } catch (final Exception e) {
    logger.log("EJCA0000", null, e);
  }
}

代码示例来源：origin: org.glassfish.connectors/connectors-runtime

/**
 * Resource adapters will signal that the connection being closed is bad.
 *
 * @param evt ConnectionEvent
 */
public void badConnectionClosed(ConnectionEvent evt) {
  if (resource.hasConnectionErrorOccurred()) {
    return;
  }
  resource.decrementCount();
  if (resource.getShareCount() == 0) {
    ManagedConnection mc = (ManagedConnection) evt.getSource();
    mc.removeConnectionEventListener(this);
    poolMgr.badResourceClosed(resource);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

ConnectionEvent

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com