Modifier and Type	Class and Description
private class	DisposableBeanAdapter.DestroyMethodSubscriber Reactive Streams Subscriber for destroy method completion.
private class	DisposableBeanAdapter.ReactiveDestroyMethodHandler Inner class to avoid a hard dependency on the Reactive Streams API at runtime.

Modifier and Type	Field and Description
private final Object	bean
private final String	beanName
private final List<DestructionAwareBeanPostProcessor>	beanPostProcessors
private static final String	CLOSE_METHOD_NAME
private static final String	DESTROY_METHOD_NAME
private String[]	destroyMethodNames
private transient Method[]	destroyMethods
private boolean	invokeAutoCloseable
private final boolean	invokeDisposableBean
private static final Log	logger
private final boolean	nonPublicAccessAllowed
private static final boolean	reactiveStreamsPresent
private static final String	SHUTDOWN_METHOD_NAME

Constructor Summary

Access	Constructor and Description
public	DisposableBeanAdapter(Object the bean instance (never `null`) bean, String the name of the bean beanName, RootBeanDefinition the merged bean definition beanDefinition, List<DestructionAwareBeanPostProcessor> the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any postProcessors) Create a new DisposableBeanAdapter for the given bean.
public	DisposableBeanAdapter(Object the bean instance (never `null`) bean, List<DestructionAwareBeanPostProcessor> the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any postProcessors) Create a new DisposableBeanAdapter for the given bean.
private	DisposableBeanAdapter(Object bean, String beanName, boolean nonPublicAccessAllowed, boolean invokeDisposableBean, boolean invokeAutoCloseable, String[] destroyMethodNames, List<DestructionAwareBeanPostProcessor> postProcessors) Create a new DisposableBeanAdapter for the given bean.

Method Summary

Modifier and Type	Method and Description
public void	destroy() Implements org.springframework.beans.factory.DisposableBean.destroy. Invoked by the containing `BeanFactory` on destruction of a bean.
private Method	determineDestroyMethod(String destroyMethodName)
private static List<DestructionAwareBeanPostProcessor>	Returns: the filtered List of DestructionAwareBeanPostProcessors filterPostProcessors(List<DestructionAwareBeanPostProcessor> the List to search processors, Object bean) Search for all DestructionAwareBeanPostProcessors in the List.
private Method	findDestroyMethod(Class<?> clazz, String name)
public static boolean	hasApplicableProcessors(Object the bean instance bean, List<DestructionAwareBeanPostProcessor> the post-processor candidates postProcessors) Check whether the given bean has destruction-aware post-processors applying to it.
public static boolean	hasDestroyMethod(Object the bean instance bean, RootBeanDefinition the corresponding bean definition beanDefinition) Check whether the given bean has any kind of destroy method to call.
pack-priv static String[]	inferDestroyMethodsIfNecessary(Class<?> target, RootBeanDefinition beanDefinition) If the current value of the given beanDefinition's "destroyMethodName" property is `AbstractBeanDefinition#INFER_METHOD`, then attempt to infer a destroy method.
private void	invokeCustomDestroyMethod(Method destroyMethod) Invoke the specified custom destroy method on the given bean.
pack-priv void	logDestroyMethodCompletion(Method destroyMethod, boolean async)
pack-priv void	logDestroyMethodException(Method destroyMethod, Throwable ex)
public void	run() Implements java.lang.Runnable.run. Runs this operation.
protected Object	writeReplace() Serializes a copy of the state of this class, filtering out non-serializable BeanPostProcessors.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bean	back to summary
private final Object bean

beanName	back to summary
private final String beanName

beanPostProcessors	back to summary
private final List<DestructionAwareBeanPostProcessor> beanPostProcessors Annotations @Nullable

CLOSE_METHOD_NAME	back to summary
private static final String CLOSE_METHOD_NAME

DESTROY_METHOD_NAME	back to summary
private static final String DESTROY_METHOD_NAME

destroyMethodNames	back to summary
private String[] destroyMethodNames Annotations @Nullable

destroyMethods	back to summary
private transient Method[] destroyMethods Annotations @Nullable

invokeAutoCloseable	back to summary
private boolean invokeAutoCloseable

invokeDisposableBean	back to summary
private final boolean invokeDisposableBean

logger	back to summary
private static final Log logger

nonPublicAccessAllowed	back to summary
private final boolean nonPublicAccessAllowed

reactiveStreamsPresent	back to summary
private static final boolean reactiveStreamsPresent

SHUTDOWN_METHOD_NAME	back to summary
private static final String SHUTDOWN_METHOD_NAME

Constructor Detail

DisposableBeanAdapter back to summary

DisposableBeanAdapter	back to summary
public DisposableBeanAdapter(Object bean, String beanName, RootBeanDefinition beanDefinition, List<DestructionAwareBeanPostProcessor> postProcessors) Create a new DisposableBeanAdapter for the given bean. Parameters bean:Object the bean instance (never `null`) beanName:String the name of the bean beanDefinition:RootBeanDefinition the merged bean definition postProcessors:List<DestructionAwareBeanPostProcessor> the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any

public DisposableBeanAdapter(Object bean, String beanName, RootBeanDefinition beanDefinition, List<DestructionAwareBeanPostProcessor> postProcessors)

Create a new DisposableBeanAdapter for the given bean.

Parameters

bean:Object: the bean instance (never null)
beanName:String: the name of the bean
beanDefinition:RootBeanDefinition: the merged bean definition
postProcessors:List<DestructionAwareBeanPostProcessor>: the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any

DisposableBeanAdapter back to summary

DisposableBeanAdapter	back to summary
public DisposableBeanAdapter(Object bean, List<DestructionAwareBeanPostProcessor> postProcessors) Create a new DisposableBeanAdapter for the given bean. Parameters bean:Object the bean instance (never `null`) postProcessors:List<DestructionAwareBeanPostProcessor> the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any

public DisposableBeanAdapter(Object bean, List<DestructionAwareBeanPostProcessor> postProcessors)

Create a new DisposableBeanAdapter for the given bean.

Parameters

bean:Object: the bean instance (never null)
postProcessors:List<DestructionAwareBeanPostProcessor>: the List of BeanPostProcessors (potentially DestructionAwareBeanPostProcessor), if any

DisposableBeanAdapter	back to summary
private DisposableBeanAdapter(Object bean, String beanName, boolean nonPublicAccessAllowed, boolean invokeDisposableBean, boolean invokeAutoCloseable, String[] destroyMethodNames, List<DestructionAwareBeanPostProcessor> postProcessors) Create a new DisposableBeanAdapter for the given bean.

Method Detail

destroy back to summary

destroy	back to summary
public void destroy() Implements org.springframework.beans.factory.DisposableBean.destroy. Doc from org.springframework.beans.factory.DisposableBean.destroy. Invoked by the containing `BeanFactory` on destruction of a bean. Annotations @Override

public void destroy()

Implements org.springframework.beans.factory.DisposableBean.destroy.

Doc from org.springframework.beans.factory.DisposableBean.destroy.

Invoked by the containing BeanFactory on destruction of a bean.

Annotations

@Override

determineDestroyMethod	back to summary
private Method determineDestroyMethod(String destroyMethodName) Annotations @Nullable

filterPostProcessors	back to summary
private static List<DestructionAwareBeanPostProcessor> filterPostProcessors(List<DestructionAwareBeanPostProcessor> processors, Object bean) Search for all DestructionAwareBeanPostProcessors in the List. Parameters processors:List<DestructionAwareBeanPostProcessor> the List to search Returns:List<DestructionAwareBeanPostProcessor> the filtered List of DestructionAwareBeanPostProcessors Annotations @Nullable

filterPostProcessors

back to summary

private static List<DestructionAwareBeanPostProcessor> filterPostProcessors(List<DestructionAwareBeanPostProcessor> processors, Object bean)

Search for all DestructionAwareBeanPostProcessors in the List.

Parameters

processors:List<DestructionAwareBeanPostProcessor>: the List to search

Returns:List<DestructionAwareBeanPostProcessor>

the filtered List of DestructionAwareBeanPostProcessors

Annotations

@Nullable

findDestroyMethod	back to summary
private Method findDestroyMethod(Class<?> clazz, String name) Annotations @Nullable

hasApplicableProcessors	back to summary
public static boolean hasApplicableProcessors(Object bean, List<DestructionAwareBeanPostProcessor> postProcessors) Check whether the given bean has destruction-aware post-processors applying to it. Parameters bean:Object the bean instance postProcessors:List<DestructionAwareBeanPostProcessor> the post-processor candidates

hasApplicableProcessors

back to summary

public static boolean hasApplicableProcessors(Object bean, List<DestructionAwareBeanPostProcessor> postProcessors)

Check whether the given bean has destruction-aware post-processors applying to it.

Parameters

bean:Object: the bean instance
postProcessors:List<DestructionAwareBeanPostProcessor>: the post-processor candidates

hasDestroyMethod	back to summary
public static boolean hasDestroyMethod(Object bean, RootBeanDefinition beanDefinition) Check whether the given bean has any kind of destroy method to call. Parameters bean:Object the bean instance beanDefinition:RootBeanDefinition the corresponding bean definition

hasDestroyMethod

back to summary

public static boolean hasDestroyMethod(Object bean, RootBeanDefinition beanDefinition)

Check whether the given bean has any kind of destroy method to call.

Parameters

bean:Object: the bean instance
beanDefinition:RootBeanDefinition: the corresponding bean definition

inferDestroyMethodsIfNecessary back to summary

inferDestroyMethodsIfNecessary	back to summary
pack-priv static String[] inferDestroyMethodsIfNecessary(Class<?> target, RootBeanDefinition beanDefinition) If the current value of the given beanDefinition's "destroyMethodName" property is `AbstractBeanDefinition#INFER_METHOD`, then attempt to infer a destroy method. Candidate methods are currently limited to public, no-arg methods named "close" or "shutdown" (whether declared locally or inherited). The given BeanDefinition's "destroyMethodName" is updated to be null if no such method is found, otherwise set to the name of the inferred method. This constant serves as the default for the `@Bean#destroyMethod` attribute and the value of the constant may also be used in XML within the `<bean destroy-method="">` or `<beans default-destroy-method="">` attributes. Also processes the `java.io.Closeable` and `java.lang.AutoCloseable` interfaces, reflectively calling the "close" method on implementing beans as well. Annotations @Nullable

pack-priv static String[] inferDestroyMethodsIfNecessary(Class<?> target, RootBeanDefinition beanDefinition)

If the current value of the given beanDefinition's "destroyMethodName" property is AbstractBeanDefinition#INFER_METHOD, then attempt to infer a destroy method. Candidate methods are currently limited to public, no-arg methods named "close" or "shutdown" (whether declared locally or inherited). The given BeanDefinition's "destroyMethodName" is updated to be null if no such method is found, otherwise set to the name of the inferred method. This constant serves as the default for the @Bean#destroyMethod attribute and the value of the constant may also be used in XML within the <bean destroy-method=""> or <beans default-destroy-method=""> attributes.

Also processes the java.io.Closeable and java.lang.AutoCloseable interfaces, reflectively calling the "close" method on implementing beans as well.

Annotations

@Nullable

invokeCustomDestroyMethod	back to summary
private void invokeCustomDestroyMethod(Method destroyMethod) Invoke the specified custom destroy method on the given bean. This implementation invokes a no-arg method if found, else checking for a method with a single boolean argument (passing in "true", assuming a "force" parameter), else logging an error.

invokeCustomDestroyMethod

back to summary

private void invokeCustomDestroyMethod(Method destroyMethod)

Invoke the specified custom destroy method on the given bean.

This implementation invokes a no-arg method if found, else checking for a method with a single boolean argument (passing in "true", assuming a "force" parameter), else logging an error.

logDestroyMethodCompletion	back to summary
pack-priv void logDestroyMethodCompletion(Method destroyMethod, boolean async)

logDestroyMethodException	back to summary
pack-priv void logDestroyMethodException(Method destroyMethod, Throwable ex)

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

writeReplace	back to summary
protected Object writeReplace() Serializes a copy of the state of this class, filtering out non-serializable BeanPostProcessors.

org.springframework.beans.factory.support back to summary

private Class DisposableBeanAdapter.DestroyMethodSubscriber

Class Inheritance

extends Object
implements Subscriber<Object>

java.lang.Object
org.springframework.beans.factory.support.DisposableBeanAdapter.DestroyMethodSubscriber

All Implemented Interfaces

org.reactivestreams.Subscriber

Reactive Streams Subscriber for destroy method completion.

Field Summary

Modifier and Type	Field and Description
private final Method	destroyMethod
private final CountDownLatch	latch

Constructor Summary

Access	Constructor and Description
public	DestroyMethodSubscriber(Method destroyMethod, CountDownLatch latch)

Method Summary

Modifier and Type	Method and Description
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(Throwable the throwable signaled t) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(Object the element signaled o) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements org.reactivestreams.Subscriber.onSubscribe. Invoked after calling `Publisher#subscribe(Subscriber)`.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

destroyMethod	back to summary
private final Method destroyMethod

latch	back to summary
private final CountDownLatch latch

Constructor Detail

DestroyMethodSubscriber	back to summary
public DestroyMethodSubscriber(Method destroyMethod, CountDownLatch latch)

Method Detail

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable t) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters t:Throwable the throwable signaled Annotations @Override

public void onError(Throwable t)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

t:Throwable: the throwable signaled

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(Object o) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters o:Object the element signaled Annotations @Override

public void onNext(Object o)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

o:Object: the element signaled

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Implements org.reactivestreams.Subscriber.onSubscribe. Doc from org.reactivestreams.Subscriber.onSubscribe. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters