diff options
Diffstat (limited to 'src/test/java/pl/edu/mimuw/cloudatlas/agent/MockEventBus.java')
-rw-r--r-- | src/test/java/pl/edu/mimuw/cloudatlas/agent/MockEventBus.java | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockEventBus.java b/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockEventBus.java new file mode 100644 index 0000000..e8f8bfa --- /dev/null +++ b/src/test/java/pl/edu/mimuw/cloudatlas/agent/MockEventBus.java @@ -0,0 +1,17 @@ +package pl.edu.mimuw.cloudatlas.agent; + +import java.util.concurrent.LinkedBlockingQueue; + +import pl.edu.mimuw.cloudatlas.agent.messages.AgentMessage; + +public class MockEventBus extends EventBus { + public LinkedBlockingQueue<AgentMessage> events; + + public MockEventBus() { + events = new LinkedBlockingQueue<AgentMessage>(); + } + + public void addMessage(AgentMessage msg) throws InterruptedException { + events.put(msg); + } +} |