Class JcaExecutorServiceManagedConnection

  • All Implemented Interfaces:
    javax.resource.spi.ManagedConnection

    public class JcaExecutorServiceManagedConnection
    extends java.lang.Object
    implements javax.resource.spi.ManagedConnection
    Author:
    Daniel Meyer
    • Constructor Detail

      • JcaExecutorServiceManagedConnection

        public JcaExecutorServiceManagedConnection()
    • Method Detail

      • getConnection

        public java.lang.Object getConnection​(javax.security.auth.Subject subject,
                                              javax.resource.spi.ConnectionRequestInfo cxRequestInfo)
                                       throws javax.resource.ResourceException
        Specified by:
        getConnection in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • associateConnection

        public void associateConnection​(java.lang.Object connection)
                                 throws javax.resource.ResourceException
        Specified by:
        associateConnection in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • cleanup

        public void cleanup()
                     throws javax.resource.ResourceException
        Specified by:
        cleanup in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • destroy

        public void destroy()
                     throws javax.resource.ResourceException
        Specified by:
        destroy in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • addConnectionEventListener

        public void addConnectionEventListener​(javax.resource.spi.ConnectionEventListener listener)
        Specified by:
        addConnectionEventListener in interface javax.resource.spi.ManagedConnection
      • removeConnectionEventListener

        public void removeConnectionEventListener​(javax.resource.spi.ConnectionEventListener listener)
        Specified by:
        removeConnectionEventListener in interface javax.resource.spi.ManagedConnection
      • getLogWriter

        public java.io.PrintWriter getLogWriter()
                                         throws javax.resource.ResourceException
        Specified by:
        getLogWriter in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • setLogWriter

        public void setLogWriter​(java.io.PrintWriter out)
                          throws javax.resource.ResourceException
        Specified by:
        setLogWriter in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • getLocalTransaction

        public javax.resource.spi.LocalTransaction getLocalTransaction()
                                                                throws javax.resource.ResourceException
        Specified by:
        getLocalTransaction in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • getXAResource

        public javax.transaction.xa.XAResource getXAResource()
                                                      throws javax.resource.ResourceException
        Specified by:
        getXAResource in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • getMetaData

        public javax.resource.spi.ManagedConnectionMetaData getMetaData()
                                                                 throws javax.resource.ResourceException
        Specified by:
        getMetaData in interface javax.resource.spi.ManagedConnection
        Throws:
        javax.resource.ResourceException
      • schedule

        public boolean schedule​(java.lang.Runnable runnable,
                                boolean isLongRunning)
      • getExecuteJobsRunnable

        public java.lang.Runnable getExecuteJobsRunnable​(java.util.List<java.lang.String> jobIds,
                                                         ProcessEngineImpl processEngine)