提交 22211a01 编写于 作者: J Juergen Hoeller

Polishing

上级 32532a88
...@@ -486,7 +486,9 @@ class ConstructorResolver { ...@@ -486,7 +486,9 @@ class ConstructorResolver {
} }
} }
candidates.sort(AutowireUtils.EXECUTABLE_COMPARATOR); if (candidates.size() > 1) { // explicitly skip immutable singletonList
candidates.sort(AutowireUtils.EXECUTABLE_COMPARATOR);
}
ConstructorArgumentValues resolvedValues = null; ConstructorArgumentValues resolvedValues = null;
boolean autowiring = (mbd.getResolvedAutowireMode() == AutowireCapableBeanFactory.AUTOWIRE_CONSTRUCTOR); boolean autowiring = (mbd.getResolvedAutowireMode() == AutowireCapableBeanFactory.AUTOWIRE_CONSTRUCTOR);
......
...@@ -850,9 +850,9 @@ public class AnnotationDrivenEventListenerTests { ...@@ -850,9 +850,9 @@ public class AnnotationDrivenEventListenerTests {
this.eventCollector.addEvent(this, event); this.eventCollector.addEvent(this, event);
} }
@Override
@EventListener @EventListener
@Async @Async
@Override
public void handleAsync(AnotherTestEvent event) { public void handleAsync(AnotherTestEvent event) {
assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content); assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content);
this.eventCollector.addEvent(this, event); this.eventCollector.addEvent(this, event);
...@@ -877,9 +877,9 @@ public class AnnotationDrivenEventListenerTests { ...@@ -877,9 +877,9 @@ public class AnnotationDrivenEventListenerTests {
this.eventCollector.addEvent(this, event); this.eventCollector.addEvent(this, event);
} }
@Override
@EventListener @EventListener
@Async @Async
@Override
public void handleAsync(AnotherTestEvent event) { public void handleAsync(AnotherTestEvent event) {
assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content); assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content);
this.eventCollector.addEvent(this, event); this.eventCollector.addEvent(this, event);
...@@ -994,20 +994,20 @@ public class AnnotationDrivenEventListenerTests { ...@@ -994,20 +994,20 @@ public class AnnotationDrivenEventListenerTests {
super.handle(event); super.handle(event);
} }
@Override
@EventListener(condition = "#payload.startsWith('OK')") @EventListener(condition = "#payload.startsWith('OK')")
@Override
public void handleString(String payload) { public void handleString(String payload) {
super.handleString(payload); super.handleString(payload);
} }
@Override
@ConditionalEvent("#root.event.timestamp > #p0") @ConditionalEvent("#root.event.timestamp > #p0")
@Override
public void handleTimestamp(Long timestamp) { public void handleTimestamp(Long timestamp) {
collectEvent(timestamp); collectEvent(timestamp);
} }
@Override
@ConditionalEvent("@conditionEvaluator.valid(#p0)") @ConditionalEvent("@conditionEvaluator.valid(#p0)")
@Override
public void handleRatio(Double ratio) { public void handleRatio(Double ratio) {
collectEvent(ratio); collectEvent(ratio);
} }
...@@ -1085,6 +1085,7 @@ public class AnnotationDrivenEventListenerTests { ...@@ -1085,6 +1085,7 @@ public class AnnotationDrivenEventListenerTests {
} }
} }
@Configuration @Configuration
@Import(UseMissingEventListener.class) @Import(UseMissingEventListener.class)
public static class MissingEventListener { public static class MissingEventListener {
...@@ -1095,6 +1096,7 @@ public class AnnotationDrivenEventListenerTests { ...@@ -1095,6 +1096,7 @@ public class AnnotationDrivenEventListenerTests {
} }
} }
@Component @Component
public static class MyEventListener { public static class MyEventListener {
...@@ -1104,6 +1106,7 @@ public class AnnotationDrivenEventListenerTests { ...@@ -1104,6 +1106,7 @@ public class AnnotationDrivenEventListenerTests {
} }
} }
public static class UseMissingEventListener { public static class UseMissingEventListener {
@Inject @Inject
......
...@@ -102,6 +102,7 @@ public abstract class AbstractDataBufferDecoder<T> extends AbstractDecoder<T> { ...@@ -102,6 +102,7 @@ public abstract class AbstractDataBufferDecoder<T> extends AbstractDecoder<T> {
* {@link #decode(DataBuffer, ResolvableType, MimeType, Map)} instead * {@link #decode(DataBuffer, ResolvableType, MimeType, Map)} instead
*/ */
@Deprecated @Deprecated
@Nullable
protected T decodeDataBuffer(DataBuffer buffer, ResolvableType elementType, protected T decodeDataBuffer(DataBuffer buffer, ResolvableType elementType,
@Nullable MimeType mimeType, @Nullable Map<String, Object> hints) { @Nullable MimeType mimeType, @Nullable Map<String, Object> hints) {
......
...@@ -155,6 +155,7 @@ public class ServerSentEventHttpMessageReader implements HttpMessageReader<Objec ...@@ -155,6 +155,7 @@ public class ServerSentEventHttpMessageReader implements HttpMessageReader<Objec
} }
} }
@Nullable
private Object decodeData(String data, ResolvableType dataType, Map<String, Object> hints) { private Object decodeData(String data, ResolvableType dataType, Map<String, Object> hints) {
if (String.class == dataType.resolve()) { if (String.class == dataType.resolve()) {
return data.substring(0, data.length() - 1); return data.substring(0, data.length() - 1);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册