From 07c9c376dfb862d0d37f70a276f59042f829ffd0 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Tue, 26 Feb 2008 04:14:42 +0000 Subject: [PATCH] Added channel capacity (now a required constructor argument). --- .../stream/ByteStreamTargetAdapterTests.java | 14 +++++++------- .../stream/CharacterStreamTargetAdapterTests.java | 8 ++++---- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetAdapterTests.java b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetAdapterTests.java index 4f5b47d0a8..2664c0fbd8 100644 --- a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetAdapterTests.java +++ b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/ByteStreamTargetAdapterTests.java @@ -64,7 +64,7 @@ public class ByteStreamTargetAdapterTests { ByteStreamTargetAdapter adapter = new ByteStreamTargetAdapter(stream); DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(3); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -84,7 +84,7 @@ public class ByteStreamTargetAdapterTests { ByteStreamTargetAdapter adapter = new ByteStreamTargetAdapter(stream); DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(2); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -104,7 +104,7 @@ public class ByteStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(5); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -124,7 +124,7 @@ public class ByteStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(2); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -149,7 +149,7 @@ public class ByteStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(5); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -173,7 +173,7 @@ public class ByteStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(2); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); @@ -197,7 +197,7 @@ public class ByteStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(2); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); SimpleMessagingTaskScheduler scheduler = new SimpleMessagingTaskScheduler(1); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); diff --git a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetAdapterTests.java b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetAdapterTests.java index cbd9365956..6297fe3c48 100644 --- a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetAdapterTests.java +++ b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamTargetAdapterTests.java @@ -90,7 +90,7 @@ public class CharacterStreamTargetAdapterTests { CharacterStreamTargetAdapter adapter = new CharacterStreamTargetAdapter(stream); DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(2); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); channel.send(new StringMessage("foo"), 0); @@ -107,7 +107,7 @@ public class CharacterStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setMaxMessagesPerTask(10); dispatcherPolicy.setReceiveTimeout(0); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); adapter.setShouldAppendNewLine(true); dispatcher.addHandler(adapter); @@ -141,7 +141,7 @@ public class CharacterStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setReceiveTimeout(0); dispatcherPolicy.setMaxMessagesPerTask(2); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); MessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); dispatcher.addHandler(adapter); TestObject testObject1 = new TestObject("foo"); @@ -160,7 +160,7 @@ public class CharacterStreamTargetAdapterTests { DispatcherPolicy dispatcherPolicy = new DispatcherPolicy(); dispatcherPolicy.setReceiveTimeout(0); dispatcherPolicy.setMaxMessagesPerTask(2); - SimpleChannel channel = new SimpleChannel(dispatcherPolicy); + SimpleChannel channel = new SimpleChannel(5, dispatcherPolicy); DefaultMessageDispatcher dispatcher = new DefaultMessageDispatcher(channel, scheduler); adapter.setShouldAppendNewLine(true); dispatcher.addHandler(adapter);