Polishing
This commit is contained in:
parent
cdf6eb95ab
commit
2bf8c0bc42
|
|
@ -1,5 +1,5 @@
|
|||
/*
|
||||
* Copyright 2002-2012 the original author or authors.
|
||||
* Copyright 2002-2015 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
|
|
@ -48,8 +48,8 @@ public interface BeanPostProcessor {
|
|||
* The returned bean instance may be a wrapper around the original.
|
||||
* @param bean the new bean instance
|
||||
* @param beanName the name of the bean
|
||||
* @return the bean instance to use, either the original or a wrapped one; if
|
||||
* {@code null}, no subsequent BeanPostProcessors will be invoked
|
||||
* @return the bean instance to use, either the original or a wrapped one;
|
||||
* if {@code null}, no subsequent BeanPostProcessors will be invoked
|
||||
* @throws org.springframework.beans.BeansException in case of errors
|
||||
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet
|
||||
*/
|
||||
|
|
@ -69,8 +69,8 @@ public interface BeanPostProcessor {
|
|||
* in contrast to all other BeanPostProcessor callbacks.
|
||||
* @param bean the new bean instance
|
||||
* @param beanName the name of the bean
|
||||
* @return the bean instance to use, either the original or a wrapped one; if
|
||||
* {@code null}, no subsequent BeanPostProcessors will be invoked
|
||||
* @return the bean instance to use, either the original or a wrapped one;
|
||||
* if {@code null}, no subsequent BeanPostProcessors will be invoked
|
||||
* @throws org.springframework.beans.BeansException in case of errors
|
||||
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet
|
||||
* @see org.springframework.beans.factory.FactoryBean
|
||||
|
|
|
|||
|
|
@ -37,12 +37,13 @@ import org.springframework.beans.factory.config.BeanPostProcessor;
|
|||
import org.springframework.beans.factory.config.DestructionAwareBeanPostProcessor;
|
||||
import org.springframework.util.Assert;
|
||||
import org.springframework.util.ClassUtils;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
import org.springframework.util.ReflectionUtils;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
/**
|
||||
* Adapter that implements the {@link DisposableBean} and {@link Runnable} interfaces
|
||||
* performing various destruction steps on a given bean instance:
|
||||
* Adapter that implements the {@link DisposableBean} and {@link Runnable}
|
||||
* interfaces performing various destruction steps on a given bean instance:
|
||||
* <ul>
|
||||
* <li>DestructionAwareBeanPostProcessors;
|
||||
* <li>the bean implementing DisposableBean itself;
|
||||
|
|
@ -218,7 +219,7 @@ class DisposableBeanAdapter implements DisposableBean, Runnable, Serializable {
|
|||
*/
|
||||
private List<DestructionAwareBeanPostProcessor> filterPostProcessors(List<BeanPostProcessor> postProcessors) {
|
||||
List<DestructionAwareBeanPostProcessor> filteredPostProcessors = null;
|
||||
if (postProcessors != null && !postProcessors.isEmpty()) {
|
||||
if (!CollectionUtils.isEmpty(postProcessors)) {
|
||||
filteredPostProcessors = new ArrayList<DestructionAwareBeanPostProcessor>(postProcessors.size());
|
||||
for (BeanPostProcessor postProcessor : postProcessors) {
|
||||
if (postProcessor instanceof DestructionAwareBeanPostProcessor) {
|
||||
|
|
@ -237,7 +238,7 @@ class DisposableBeanAdapter implements DisposableBean, Runnable, Serializable {
|
|||
|
||||
@Override
|
||||
public void destroy() {
|
||||
if (this.beanPostProcessors != null && !this.beanPostProcessors.isEmpty()) {
|
||||
if (!CollectionUtils.isEmpty(this.beanPostProcessors)) {
|
||||
for (DestructionAwareBeanPostProcessor processor : this.beanPostProcessors) {
|
||||
processor.postProcessBeforeDestruction(this.bean, this.beanName);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -55,6 +55,7 @@ public abstract class ReflectionUtils {
|
|||
|
||||
private static final Field[] NO_FIELDS = {};
|
||||
|
||||
|
||||
/**
|
||||
* Cache for {@link Class#getDeclaredMethods()} plus equivalent default methods
|
||||
* from Java 8 based interfaces, allowing for fast iteration.
|
||||
|
|
@ -114,7 +115,7 @@ public abstract class ReflectionUtils {
|
|||
* <p>Thrown exceptions are handled via a call to {@link #handleReflectionException(Exception)}.
|
||||
* @param field the field to set
|
||||
* @param target the target object on which to set the field
|
||||
* @param value the value to set; may be {@code null}
|
||||
* @param value the value to set (may be {@code null})
|
||||
*/
|
||||
public static void setField(Field field, Object target, Object value) {
|
||||
try {
|
||||
|
|
@ -296,12 +297,11 @@ public abstract class ReflectionUtils {
|
|||
|
||||
/**
|
||||
* Rethrow the given {@link Throwable exception}, which is presumably the
|
||||
* <em>target exception</em> of an {@link InvocationTargetException}. Should
|
||||
* only be called if no checked exception is expected to be thrown by the
|
||||
* target method.
|
||||
* <em>target exception</em> of an {@link InvocationTargetException}.
|
||||
* Should only be called if no checked exception is expected to be thrown
|
||||
* by the target method.
|
||||
* <p>Rethrows the underlying exception cast to an {@link RuntimeException} or
|
||||
* {@link Error} if appropriate; otherwise, throws an
|
||||
* {@link IllegalStateException}.
|
||||
* {@link Error} if appropriate; otherwise, throws an {@link IllegalStateException}.
|
||||
* @param ex the exception to rethrow
|
||||
* @throws RuntimeException the rethrown exception
|
||||
*/
|
||||
|
|
@ -317,12 +317,11 @@ public abstract class ReflectionUtils {
|
|||
|
||||
/**
|
||||
* Rethrow the given {@link Throwable exception}, which is presumably the
|
||||
* <em>target exception</em> of an {@link InvocationTargetException}. Should
|
||||
* only be called if no checked exception is expected to be thrown by the
|
||||
* target method.
|
||||
* <em>target exception</em> of an {@link InvocationTargetException}.
|
||||
* Should only be called if no checked exception is expected to be thrown
|
||||
* by the target method.
|
||||
* <p>Rethrows the underlying exception cast to an {@link Exception} or
|
||||
* {@link Error} if appropriate; otherwise, throws an
|
||||
* {@link IllegalStateException}.
|
||||
* {@link Error} if appropriate; otherwise, throws an {@link IllegalStateException}.
|
||||
* @param ex the exception to rethrow
|
||||
* @throws Exception the rethrown exception (in case of a checked exception)
|
||||
*/
|
||||
|
|
@ -338,8 +337,8 @@ public abstract class ReflectionUtils {
|
|||
|
||||
/**
|
||||
* Determine whether the given method explicitly declares the given
|
||||
* exception or one of its superclasses, which means that an exception of
|
||||
* that type can be propagated as-is within a reflective invocation.
|
||||
* exception or one of its superclasses, which means that an exception
|
||||
* of that type can be propagated as-is within a reflective invocation.
|
||||
* @param method the declaring method
|
||||
* @param exceptionType the exception to throw
|
||||
* @return {@code true} if the exception can be thrown as-is;
|
||||
|
|
|
|||
|
|
@ -1,5 +1,5 @@
|
|||
/*
|
||||
* Copyright 2002-2014 the original author or authors.
|
||||
* Copyright 2002-2015 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
|
|
@ -30,7 +30,6 @@ import org.springframework.web.socket.CloseStatus;
|
|||
import org.springframework.web.socket.WebSocketMessage;
|
||||
import org.springframework.web.socket.WebSocketSession;
|
||||
|
||||
|
||||
/**
|
||||
* Wraps a {@link org.springframework.web.socket.WebSocketSession} and guarantees
|
||||
* only one thread can send messages at a time.
|
||||
|
|
@ -45,7 +44,7 @@ import org.springframework.web.socket.WebSocketSession;
|
|||
*/
|
||||
public class ConcurrentWebSocketSessionDecorator extends WebSocketSessionDecorator {
|
||||
|
||||
private static final Log logger = LogFactory.getLog("_" + ConcurrentWebSocketSessionDecorator.class.getName());
|
||||
private static final Log logger = LogFactory.getLog(ConcurrentWebSocketSessionDecorator.class);
|
||||
|
||||
|
||||
private final Queue<WebSocketMessage<?>> buffer = new LinkedBlockingQueue<WebSocketMessage<?>>();
|
||||
|
|
|
|||
Loading…
Reference in New Issue