Commit 0f2ae622 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa

fixes #269

renamed distributor strategy
parent 3e20d27f
......@@ -25,7 +25,7 @@ import teetime.stage.basic.distributor.Distributor;
*
* @since 1.0
*/
public class BlockingRoundRobinStrategy implements IDistributorStrategy {
public class BlockingBusyWaitingRoundRobinStrategy implements IDistributorStrategy {
private int index;
......
......@@ -32,7 +32,7 @@ import org.junit.Test;
import org.junit.rules.ExpectedException;
import teetime.framework.ExecutionException;
import teetime.stage.basic.distributor.strategy.BlockingRoundRobinStrategy;
import teetime.stage.basic.distributor.strategy.BlockingBusyWaitingRoundRobinStrategy;
import teetime.stage.basic.distributor.strategy.CloneStrategy;
import teetime.stage.basic.distributor.strategy.CopyByReferenceStrategy;
import teetime.stage.basic.distributor.strategy.NonBlockingRoundRobinStrategy;
......@@ -60,7 +60,7 @@ public class DistributorTest {
@Test
public void roundRobinShouldWork() {
distributor.setStrategy(new BlockingRoundRobinStrategy());
distributor.setStrategy(new BlockingBusyWaitingRoundRobinStrategy());
test(distributor).and().send(1, 2, 3, 4, 5).to(distributor.getInputPort()).and().receive(firstIntegers).from(distributor.getNewOutputPort()).and()
.receive(secondIntegers).from(distributor.getNewOutputPort()).start();
......@@ -71,7 +71,7 @@ public class DistributorTest {
@Test
public void singleElementRoundRobinShouldWork() {
distributor.setStrategy(new BlockingRoundRobinStrategy());
distributor.setStrategy(new BlockingBusyWaitingRoundRobinStrategy());
test(distributor).and().send(1).to(distributor.getInputPort()).and().receive(firstIntegers).from(distributor.getNewOutputPort()).and()
.receive(secondIntegers)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment