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

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

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

ConnectionEvent.setConnectionHandle介绍

[英]Set the connection handle. Used for CONNECTION_CLOSED event
[中]设置连接句柄。用于连接\u关闭事件

代码示例

代码示例来源:origin: camunda/camunda-bpm-platform

void closeHandle(JcaExecutorServiceConnection handle) {
 ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
 event.setConnectionHandle(handle);
 for (ConnectionEventListener cel : listeners) {
  cel.connectionClosed(event);
 }
}
public PrintWriter getLogWriter() throws ResourceException {

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

private Object handleCloseMethod(Object proxy, Method method,
      Object[] args) {
    handles.remove(proxy);
    associatedHandle = null;
    ConnectionEvent event = new ConnectionEvent(ManagedConnectionImpl.this,
        ConnectionEvent.CONNECTION_CLOSED);
    event.setConnectionHandle(proxy);
    sendEvent(event);
    return null;
  }
}

代码示例来源:origin: jpox/jpox

void notifyTxRollback(PersistenceManagerImpl handle)
{
  ConnectionEvent ce = new ConnectionEvent(this, ConnectionEvent.LOCAL_TRANSACTION_ROLLEDBACK, null);
  ce.setConnectionHandle(handle);
  Collection localCels = null;
  synchronized (cels)
  {
    localCels = new ArrayList(cels);
  }
  for (Iterator i = localCels.iterator(); i.hasNext(); )
  {
    ((ConnectionEventListener)i.next()).localTransactionRolledback(ce);
  }
}

代码示例来源:origin: org.tranql/tranql-connector

public void connectionClosed(U handle) {
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  //count down in case sending the event results in a handle getting removed.
  for (int i = listeners.size() - 1; i >= 0; i--) {
    ConnectionEventListener listener = listeners.get(i);
    listener.connectionClosed(event);
  }
}

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

public void close(Object closingHandle) throws ResourceException {
  LOG.fine("Closing handle: " + closingHandle);
  ConnectionEvent coEvent = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  coEvent.setConnectionHandle(closingHandle);
  sendEvent(coEvent);
}

代码示例来源:origin: net.java.xadisk/xadisk

void connectionClosed(XADiskConnection connection) {
  connectionHandles.remove(connection);
  ConnectionEvent connectionEvent = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  connectionEvent.setConnectionHandle(connection);
  raiseConnectionEvent(connectionEvent);
}

代码示例来源:origin: fish.payara.cloud.connectors.azuresb/azure-sb-jca-api

void removeHandle(AzureSBConnectionImpl handle) {
  connectionHandles.remove(handle);
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  for (ConnectionEventListener listener : listeners) {
    listener.connectionClosed(event);
  }
}

代码示例来源:origin: payara/Cloud-Connectors

void removeHandle(MQTTConnectionImpl handle) {
  connectionHandles.remove(handle);
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  for (ConnectionEventListener listener : listeners) {
    listener.connectionClosed(event);
  }
}

代码示例来源:origin: payara/Cloud-Connectors

void remove(KafkaConnectionImpl conn) {
  connectionHandles.remove(conn);
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(conn);
  for (ConnectionEventListener listener : listeners) {
    listener.connectionClosed(event);
  }
}

代码示例来源:origin: payara/Cloud-Connectors

void removeHandle(AmazonSQSConnection connection) {
  connectionHandles.remove(connection);
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(connection);
  for (ConnectionEventListener listener : listeners) {
    listener.connectionClosed(event);
  }
}

代码示例来源:origin: payara/Cloud-Connectors

void removeHandle(AzureSBConnectionImpl handle) {
  connectionHandles.remove(handle);
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  for (ConnectionEventListener listener : listeners) {
    listener.connectionClosed(event);
  }
}

代码示例来源:origin: ModeShape/modeshape

/**
 * Close handle
 * 
 * @param handle The handle
 */
protected void closeHandle( JcrSessionHandle handle ) {
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  for (ConnectionEventListener cel : listeners) {
    cel.connectionClosed(event);
  }
}

代码示例来源:origin: org.apache.jackrabbit/jackrabbit-jca

/**
 * Send event.
 */
private void sendEvent(int type, Object handle, Exception cause) {
  ConnectionEvent event = new ConnectionEvent(this, type, cause);
  if (handle != null) {
    event.setConnectionHandle(handle);
  }
  sendEvent(event);
}

代码示例来源:origin: org.tomitribe/chatterbox-twitter-impl

void closeHandle(TwitterConnection handle) {
  ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(handle);
  for (ConnectionEventListener cel : listeners) {
    cel.connectionClosed(event);
  }
}

代码示例来源:origin: com.caucho/resin

void close()
{
 if (_listener != null) {
  ConnectionEvent evt;
  evt = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  evt.setConnectionHandle(this);
  _listener.connectionClosed(evt);
 }
}

代码示例来源:origin: net.sf.tsl2nano/tsl2.nano.serviceaccess

/**
 * @param con
 */
protected void detachConnection(FsConnectionImpl con) {
  LOG.debug("detachConnection con=" + con);
  con.setManagedConnection(null);
  connections.remove(con);
  final ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
  event.setConnectionHandle(con);
  fireConnectionEvent(event);
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-storage-sql

private void sendEvent(int type, ConnectionImpl connection, Exception cause) {
  ConnectionEvent event = new ConnectionEvent(this, type, cause);
  if (connection != null) {
    event.setConnectionHandle(connection);
  }
  sendEvent(event);
}

代码示例来源:origin: apache/jackrabbit

/**
 * Send event.
 */
private void sendEvent(int type, Object handle, Exception cause) {
  ConnectionEvent event = new ConnectionEvent(this, type, cause);
  if (handle != null) {
    event.setConnectionHandle(handle);
  }
  sendEvent(event);
}

代码示例来源:origin: com.googlecode.cassandra-jca/cassandra-jca-impl

@Override
  public void close() {
//        logger.info("void close()");
//        logger.info("this = " + this);
    ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
    event.setConnectionHandle(cassandraConnection);

    for (ConnectionEventListener cel : listeners) {
      cel.connectionClosed(event);
    }
  }

代码示例来源:origin: io.vertx/vertx-jca-adapter

/**
 * Close handle
 *
 * @param handle
 *          The handle
 */
void closeHandle(VertxConnectionImpl handle) {
 ConnectionEvent event = new ConnectionEvent(this,
   ConnectionEvent.CONNECTION_CLOSED);
 event.setConnectionHandle(handle);
 for (ConnectionEventListener cel : listeners) {
  cel.connectionClosed(event);
 }
}

相关文章