diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractSubscribableChannel.java b/org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractSubscribableChannel.java index 88b6662cc2..b509f3d12f 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractSubscribableChannel.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/channel/AbstractSubscribableChannel.java @@ -45,7 +45,7 @@ public abstract class AbstractSubscribableChannel extends AbstractMessageChannel private MessageDispatcher getRequiredDispatcher() { MessageDispatcher dispatcher = this.getDispatcher(); - Assert.state(dispatcher != null, "dispatcher must not be null"); + Assert.state(dispatcher != null, "'dispatcher' must not be null"); return dispatcher; } diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/channel/ExecutorChannel.java b/org.springframework.integration/src/main/java/org/springframework/integration/channel/ExecutorChannel.java index 24ca565e4c..79ff312cd2 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/channel/ExecutorChannel.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/channel/ExecutorChannel.java @@ -75,7 +75,7 @@ public class ExecutorChannel extends AbstractSubscribableChannel { ExecutorDecoratingDispatcher(AbstractUnicastDispatcher dispatcher, TaskExecutor taskExecutor) { - Assert.notNull(dispatcher, "dispatcher must not be null"); + Assert.notNull(dispatcher, "'dispatcher' must not be null"); this.targetDispatcher = dispatcher; this.taskExecutor = taskExecutor != null ? taskExecutor : new ConcurrentTaskExecutor(Executors.newSingleThreadExecutor());