Fix Checkstyle violations

This commit is contained in:
Artem Bilan
2016-08-18 14:32:46 -04:00
parent 6ccad0daa8
commit d6045aa48b
3 changed files with 11 additions and 15 deletions

View File

@@ -139,7 +139,7 @@ public class ReactiveConsumer extends AbstractEndpoint {
}
private static class SubscribableChannelPublisherAdapter
private final static class SubscribableChannelPublisherAdapter
implements Publisher<Message<?>>, Subscriber<Message<?>>, Subscription {
private final DirectProcessor<Message<?>> delegate = DirectProcessor.create();

View File

@@ -168,7 +168,7 @@ public abstract class AbstractMessageHandler extends IntegrationObjectSupport im
@Override
public void onComplete() {
System.out.println("onComplete()");
}
protected abstract void handleMessageInternal(Message<?> message) throws Exception;