org.jboss.ejb.plugins
Class CleanShutdownInterceptor

java.lang.Object
  org.jboss.ejb.plugins.AbstractInterceptor (src) 
      org.jboss.ejb.plugins.CleanShutdownInterceptor

All Implemented Interfaces:

AllowedOperationsFlags (src) , ContainerPlugin (src) , Interceptor (src) , Service (src)

public class CleanShutdownInterceptor

extends AbstractInterceptor (src)

Track the incoming invocations and when shuting down a container (stop or destroy), waits for current invocations to finish before returning the stop or destroy call. This interceptor can be important in clustered environment where shuting down a node doesn't necessarly mean that an application cannot be reached: other nodes may still be servicing. Consequently, it is important to have a clean shutdown to keep a coherent behaviour cluster-wide. To avoid strange or inefficient behaviour, the facade session bean (if any) should be stopped first thus not blocking invocations in a middle-step (i.e. facade making multiple invocations to "sub-beans": if a "sub-bean" is shut down, the facade will get an exception in the middle of its activity)

See Also:

container

protected Container (src)  container

ejbModule

protected EjbModule (src)  ejbModule

ejbModuleName

protected java.lang.String ejbModuleName

allowInvocations

protected boolean allowInvocations

allowRemoteInvocations

protected boolean allowRemoteInvocations

isDebugEnabled

protected boolean isDebugEnabled

runningInvocations

public long runningInvocations

runningHomeInvocations

public long runningHomeInvocations

shutdownTimeout

public long shutdownTimeout

readAcquireTimeMs

public long readAcquireTimeMs

rwLock

protected ReentrantWriterPreferenceReadWriteLock rwLock

CleanShutdownInterceptor

public CleanShutdownInterceptor()

onlyAllowLocalInvocations

public void onlyAllowLocalInvocations()

waitForNoMoreInvocations

public void waitForNoMoreInvocations()

create

public void create()
            throws java.lang.Exception

Description copied from interface: Service (src)

create the service, do expensive operations etc

Specified by:

create in interface Service (src)

Overrides:

create in class AbstractInterceptor (src)

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Description copied from interface: Service (src)

start the service, create is already called

Specified by:

start in interface Service (src)

Overrides:

start in class AbstractInterceptor (src)

Throws:

java.lang.Exception

stop

public void stop()

Description copied from interface: Service (src)

stop the service

Specified by:

stop in interface Service (src)

Overrides:

stop in class AbstractInterceptor (src)

destroy

public void destroy()

Description copied from interface: Service (src)

destroy the service, tear down

Specified by:

destroy in interface Service (src)

Overrides:

destroy in class AbstractInterceptor (src)

invokeHome

public java.lang.Object invokeHome(Invocation (src)  mi)
                            throws java.lang.Exception

Description copied from interface: Interceptor (src)

???

Specified by:

invokeHome in interface Interceptor (src)

Overrides:

invokeHome in class AbstractInterceptor (src)

Throws:

java.lang.Exception

invoke

public java.lang.Object invoke(Invocation (src)  mi)
                        throws java.lang.Exception

Description copied from interface: Interceptor (src)

???

Specified by:

invoke in interface Interceptor (src)

Overrides:

invoke in class AbstractInterceptor (src)

Throws:

java.lang.Exception

getContainer

public Container (src)  getContainer()

Overrides:

getContainer in class AbstractInterceptor (src)

setContainer

public void setContainer(Container (src)  con)

This callback is set by the container so that the plugin may access it

Specified by:

setContainer in interface ContainerPlugin (src)

Overrides:

setContainer in class AbstractInterceptor (src)

Parameters:

con - The container using this plugin.

forbidInvocations

protected void forbidInvocations()

purgeRunningInvocations

protected void purgeRunningInvocations()

getOrigin

protected java.lang.String getOrigin(Invocation (src)  mi)

setOrigin

protected void setOrigin(Invocation (src)  mi)

revertOrigin

protected void revertOrigin(Invocation (src)  mi,
                            java.lang.String origin)

containerIsAboutToStop

protected void containerIsAboutToStop()