@Test
	public void testCreateTopicPublisher() {
		TopicPublisher pub;
		try {
			pub = BrokerFactoryImpl.createPublisher("TestTopic");
			assertNotNull("TopicPublisher is null", pub);
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (BrokerError e) {
			fail("Unexpected exception while creating publisher");
		} catch (Exception e) {
			logger.error("Error while creating publisher", e);
		}
	}