committed by
Marius Bogoevici
parent
0626cc8c07
commit
6c442b7421
@@ -46,6 +46,7 @@ import org.springframework.util.MimeTypeUtils;
|
||||
* @author David Turanski
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
@SuppressWarnings("unchecked")
|
||||
public abstract class AbstractBinderTests<B extends AbstractTestBinder<? extends AbstractBinder<MessageChannel, CP, PP>, CP, PP>, CP extends ConsumerProperties, PP extends ProducerProperties> {
|
||||
|
||||
protected B testBinder;
|
||||
|
||||
@@ -125,6 +125,7 @@ public class BindableProxyFactory implements MethodInterceptor, FactoryBean<Obje
|
||||
Input input = AnnotationUtils.findAnnotation(method, Input.class);
|
||||
if (input != null) {
|
||||
String name = BindingBeanDefinitionRegistryUtils.getChannelName(input, method);
|
||||
@SuppressWarnings("unchecked")
|
||||
Class<? extends MessageChannel> channelType = (Class<? extends MessageChannel>) method.getReturnType();
|
||||
MessageChannel sharedChannel = locateSharedChannel(name);
|
||||
if (sharedChannel == null) {
|
||||
@@ -145,6 +146,7 @@ public class BindableProxyFactory implements MethodInterceptor, FactoryBean<Obje
|
||||
Output output = AnnotationUtils.findAnnotation(method, Output.class);
|
||||
if (output != null) {
|
||||
String name = BindingBeanDefinitionRegistryUtils.getChannelName(output, method);
|
||||
@SuppressWarnings("unchecked")
|
||||
Class<? extends MessageChannel> channelType = (Class<? extends MessageChannel>) method.getReturnType();
|
||||
MessageChannel sharedChannel = locateSharedChannel(name);
|
||||
if (sharedChannel == null) {
|
||||
|
||||
@@ -49,6 +49,7 @@ public class BinderAwareChannelResolver extends BeanFactoryMessageChannelDestina
|
||||
|
||||
private ConfigurableListableBeanFactory beanFactory;
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
public BinderAwareChannelResolver(BinderFactory binderFactory,
|
||||
ChannelBindingServiceProperties channelBindingServiceProperties,
|
||||
DynamicDestinationsBindable dynamicDestinationsBindable,
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2015 the original author or authors.
|
||||
* Copyright 2015-2016 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.
|
||||
@@ -163,7 +163,7 @@ public abstract class AbstractFromMessageConverter extends AbstractMessageConver
|
||||
* Not supported by default
|
||||
*/
|
||||
@Override
|
||||
public Object convertToInternal(Object payload, MessageHeaders headers) {
|
||||
public Object convertToInternal(Object payload, MessageHeaders headers, Object conversionHint) {
|
||||
throw new UnsupportedOperationException("'convertTo' not supported");
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user