Skip to content

Commit

Permalink
Polishing
Browse files Browse the repository at this point in the history
  • Loading branch information
jhoeller committed Nov 13, 2019
1 parent 32532a8 commit 22211a0
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 6 deletions.
Expand Up @@ -486,7 +486,9 @@ public BeanWrapper instantiateUsingFactoryMethod(
}
}

candidates.sort(AutowireUtils.EXECUTABLE_COMPARATOR);
if (candidates.size() > 1) { // explicitly skip immutable singletonList
candidates.sort(AutowireUtils.EXECUTABLE_COMPARATOR);
}

ConstructorArgumentValues resolvedValues = null;
boolean autowiring = (mbd.getResolvedAutowireMode() == AutowireCapableBeanFactory.AUTOWIRE_CONSTRUCTOR);
Expand Down
Expand Up @@ -850,9 +850,9 @@ public void handleIt(TestEvent event) {
this.eventCollector.addEvent(this, event);
}

@Override
@EventListener
@Async
@Override
public void handleAsync(AnotherTestEvent event) {
assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content);
this.eventCollector.addEvent(this, event);
Expand All @@ -877,9 +877,9 @@ public void handleIt(TestEvent event) {
this.eventCollector.addEvent(this, event);
}

@Override
@EventListener
@Async
@Override
public void handleAsync(AnotherTestEvent event) {
assertThat(Thread.currentThread().getName()).isNotEqualTo(event.content);
this.eventCollector.addEvent(this, event);
Expand Down Expand Up @@ -994,20 +994,20 @@ public void handle(TestEvent event) {
super.handle(event);
}

@Override
@EventListener(condition = "#payload.startsWith('OK')")
@Override
public void handleString(String payload) {
super.handleString(payload);
}

@Override
@ConditionalEvent("#root.event.timestamp > #p0")
@Override
public void handleTimestamp(Long timestamp) {
collectEvent(timestamp);
}

@Override
@ConditionalEvent("@conditionEvaluator.valid(#p0)")
@Override
public void handleRatio(Double ratio) {
collectEvent(ratio);
}
Expand Down Expand Up @@ -1085,6 +1085,7 @@ public String getConversationId() {
}
}


@Configuration
@Import(UseMissingEventListener.class)
public static class MissingEventListener {
Expand All @@ -1095,6 +1096,7 @@ public MyEventListener missing() {
}
}


@Component
public static class MyEventListener {

Expand All @@ -1104,6 +1106,7 @@ public void hear(TestEvent e) {
}
}


public static class UseMissingEventListener {

@Inject
Expand Down
Expand Up @@ -102,6 +102,7 @@ public Mono<T> decodeToMono(Publisher<DataBuffer> input, ResolvableType elementT
* {@link #decode(DataBuffer, ResolvableType, MimeType, Map)} instead
*/
@Deprecated
@Nullable
protected T decodeDataBuffer(DataBuffer buffer, ResolvableType elementType,
@Nullable MimeType mimeType, @Nullable Map<String, Object> hints) {

Expand Down
Expand Up @@ -155,6 +155,7 @@ else if (line.startsWith(":")) {
}
}

@Nullable
private Object decodeData(String data, ResolvableType dataType, Map<String, Object> hints) {
if (String.class == dataType.resolve()) {
return data.substring(0, data.length() - 1);
Expand Down

0 comments on commit 22211a0

Please sign in to comment.