echo '================================================START======================================='
./mq_dsm_servers.sh start
+sleep 60
echo '==================================== INTEGRATION TESTS ====================================='
cd /usr/iotswsec/servers/api-integration-tests
mvn test
private Producer<byte[], byte[]> mProducer = null;
+ @SuppressWarnings("PMD.ConstructorCallsOverridableMethod")
public KafkaProducerWrapper(String brokerAddress, String topic) {
mTopicName = topic.replace("/", ".");
this.kafkaHost = kafkaHost;
this.topicManager = new TopicManager();
topicManager.setKafkaInformation(zookeperHost, kafkaHost);
- Topic topic = new Topic(topicName, TOPIC_TYPE, getTopicManager());
+ Topic topic = new Topic(topicName, TOPIC_TYPE, topicManager);
this.kafkaConsumer = new KafkaConsumerWrapper(zookeperHost, kafkaHost, topic);
if (topicManager.getTopic(topicName) == null) {
topicManager.createTopic(topic);