	@Test
	public void subscribeTest() {

		replay(this.consumerOne, this.consumerTwo, this.publisher);

		assertFalse(bus.subscribers.containsKey(EventOne.class));
		assertFalse(bus.subscribers.containsKey(EventTwo.class));

		bus.subscribe(SubscriberOne.class);
		bus.subscribe(SubscriberTwo.class);

		assertTrue(bus.subscribers.containsKey(EventOne.class));
		assertEquals(1, bus.subscribers.get(EventOne.class).size());
		assertTrue(bus.subscribers.containsKey(EventTwo.class));
		assertEquals(2, bus.subscribers.get(EventTwo.class).size());

		verify(this.consumerOne, this.consumerTwo, this.publisher);
	}