diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java b/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java index 49a225e25e..b8a9540a2d 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java @@ -58,7 +58,7 @@ public class QueueChannel extends AbstractMessageChannel { public QueueChannel(int capacity, DispatcherPolicy dispatcherPolicy) { super((dispatcherPolicy != null) ? dispatcherPolicy : new DispatcherPolicy()); Assert.isTrue(capacity > 0, "The capacity must be a positive integer. " + - "For a zero-capacity alternative, consider '" + RendezvousChannel.class + "'"); + "For a zero-capacity alternative, consider using a 'RendezvousChannel'."); this.queue = new LinkedBlockingQueue>(capacity); }