diff options
author | Marcin Chrzanowski <marcin.j.chrzanowski@gmail.com> | 2019-12-27 11:28:46 +0100 |
---|---|---|
committer | Marcin Chrzanowski <marcin.j.chrzanowski@gmail.com> | 2019-12-27 11:28:46 +0100 |
commit | afa32431d242d60471e5431d654784ee64b63bbf (patch) | |
tree | 5d379373a70c8e828ae0459600dd2195a27eabc2 /src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java | |
parent | 8b076ed54b692381a3c1410b704bdad33ad5ca0b (diff) |
Begin Stanik impelementation
* Get cloned hierarchy
* Test on empty hierarchy
Diffstat (limited to 'src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java')
-rw-r--r-- | src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java b/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java new file mode 100644 index 0000000..1da50ad --- /dev/null +++ b/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockExecutor.java @@ -0,0 +1,24 @@ +package pl.edu.mimuw.cloudatlas.agent; + +import java.util.concurrent.LinkedBlockingQueue; + +import pl.edu.mimuw.cloudatlas.agent.modules.Module; +import pl.edu.mimuw.cloudatlas.agent.messages.AgentMessage; + +/* + * Instead of passing messages to an EventBus, this one just collects them + * locally for inspection in unit tests. + */ +public class MockExecutor extends Executor { + public LinkedBlockingQueue<AgentMessage> messagesToPass; + + public MockExecutor(Module module) { + super(module); + messagesToPass = new LinkedBlockingQueue<AgentMessage>(); + } + + @Override + public void passMessage(AgentMessage message) throws InterruptedException { + messagesToPass.put(message); + } +} |