SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cleanup todo items

Browse Source 
This resolves #485
This commit is contained in:
Ilayaperumal Gopinathan
2016-04-15 19:28:21 +05:30
committed by Marius Bogoevici
parent 842d11ae91
commit c815420305
3 changed files with 0 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
View File

@@ -28,7 +28,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.AmqpConnectException;
import org.springframework.amqp.UncategorizedAmqpException;
import org.springframework.amqp.core.AnonymousQueue;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
@@ -490,15 +489,6 @@ public class RabbitMessageChannelBinder extends AbstractBinder<MessageChannel, E
logger.debug("Declaration of queue: " + queue.getName() + " deferred - connection not available");
}
}
catch (UncategorizedAmqpException e) {
if (e.getCause() instanceof NullPointerException) {
// Temporary fix for https://jira.spring.io/browse/AMQP-565
// TODO remove once Spring AMQP is upgraded beyond 1.5.4
}
else {
throw e;
}
}
addToAutoDeclareContext(beanName, queue);
}

1
spring-cloud-stream-rxjava/src/main/java/org/springframework/cloud/stream/annotation/rxjava/SubjectMessageHandler.java
View File

@@ -141,7 +141,6 @@ public class SubjectMessageHandler extends AbstractMessageProducingHandler imple
}
@Override
//todo: support module input type
protected void handleMessageInternal(Message<?> message) throws Exception {
subject.onNext(message.getPayload());
}

1
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/StreamListenerAnnotationBeanPostProcessor.java
View File

@@ -97,7 +97,6 @@ public class StreamListenerAnnotationBeanPostProcessor implements BeanPostProces
" already existing for " + mappedBindings.get(streamListener.value()).getShortLogMessage());
}
mappedBindings.put(streamListener.value(), invocableHandlerMethod);
// TODO: support pollable channels https://github.com/spring-cloud/spring-cloud-stream/issues/436
SubscribableChannel channel = applicationContext.getBean(streamListener.value(),
SubscribableChannel.class);
final String defaultOutputChannel = extractDefaultOutput(method);