public class JcaExecutorServiceManagedConnection extends Object implements javax.resource.spi.ManagedConnection
Modifier and Type | Field and Description |
---|---|
protected JcaExecutorServiceConnectionImpl |
connection |
protected ExecutorService |
delegate |
protected List<javax.resource.spi.ConnectionEventListener> |
listeners |
protected PrintWriter |
logwriter |
protected JcaExecutorServiceManagedConnectionFactory |
mcf |
Constructor and Description |
---|
JcaExecutorServiceManagedConnection() |
JcaExecutorServiceManagedConnection(JcaExecutorServiceManagedConnectionFactory mcf) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionEventListener(javax.resource.spi.ConnectionEventListener listener) |
void |
associateConnection(Object connection) |
void |
cleanup() |
void |
destroy() |
Object |
getConnection(Subject subject,
javax.resource.spi.ConnectionRequestInfo cxRequestInfo) |
Runnable |
getExecuteJobsRunnable(List<String> jobIds,
ProcessEngineImpl processEngine) |
javax.resource.spi.LocalTransaction |
getLocalTransaction() |
PrintWriter |
getLogWriter() |
javax.resource.spi.ManagedConnectionMetaData |
getMetaData() |
XAResource |
getXAResource() |
void |
removeConnectionEventListener(javax.resource.spi.ConnectionEventListener listener) |
boolean |
schedule(Runnable runnable,
boolean isLongRunning) |
void |
setLogWriter(PrintWriter out) |
protected PrintWriter logwriter
protected JcaExecutorServiceManagedConnectionFactory mcf
protected List<javax.resource.spi.ConnectionEventListener> listeners
protected JcaExecutorServiceConnectionImpl connection
protected ExecutorService delegate
public JcaExecutorServiceManagedConnection()
public JcaExecutorServiceManagedConnection(JcaExecutorServiceManagedConnectionFactory mcf)
public Object getConnection(Subject subject, javax.resource.spi.ConnectionRequestInfo cxRequestInfo) throws javax.resource.ResourceException
getConnection
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void associateConnection(Object connection) throws javax.resource.ResourceException
associateConnection
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void cleanup() throws javax.resource.ResourceException
cleanup
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void destroy() throws javax.resource.ResourceException
destroy
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void addConnectionEventListener(javax.resource.spi.ConnectionEventListener listener)
addConnectionEventListener
in interface javax.resource.spi.ManagedConnection
public void removeConnectionEventListener(javax.resource.spi.ConnectionEventListener listener)
removeConnectionEventListener
in interface javax.resource.spi.ManagedConnection
public PrintWriter getLogWriter() throws javax.resource.ResourceException
getLogWriter
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void setLogWriter(PrintWriter out) throws javax.resource.ResourceException
setLogWriter
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public javax.resource.spi.LocalTransaction getLocalTransaction() throws javax.resource.ResourceException
getLocalTransaction
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public XAResource getXAResource() throws javax.resource.ResourceException
getXAResource
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public javax.resource.spi.ManagedConnectionMetaData getMetaData() throws javax.resource.ResourceException
getMetaData
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public boolean schedule(Runnable runnable, boolean isLongRunning)
public Runnable getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
Copyright © 2017. All rights reserved.