- try {
- // ..checking for topic exist is commented
- // if (!topicTestObj.topicExist(url, props, hm)) {
- // throw new Exception("Topic does not exist");
- // } else {
- DME2Client sender = new DME2Client(new URI(url), 5000L);
- sender.setAllowAllHttpReturnCodes(true);
- sender.setMethod(methodType);
- String subContextPathConsumer = props.getProperty("SubContextPathConsumer") + props.getProperty("newTopic")
- + "/" + props.getProperty("group") + "/" + props.getProperty("id") + "?"
- + props.getProperty("filterType");
+ public void testConsumerFilter() {
+ LOGGER.info("Test case consumer filter initiated");
+ Properties props = LoadPropertyFile.getPropertyFileDataProducer();
+ String latitude = props.getProperty("Latitude");
+ String longitude = props.getProperty("Longitude");
+ String version = props.getProperty("Version");
+ String serviceName = props.getProperty("ServiceName");
+ String env = props.getProperty("Environment");
+ String partner = props.getProperty("Partner");
+ String protocol = props.getProperty("Protocol");
+ String methodType = props.getProperty("MethodTypeGet");
+ String user = props.getProperty("user");
+ String password = props.getProperty("password");
+ String contenttype = props.getProperty("contenttype");
+ String url =
+ protocol + "://DME2SEARCH/" + "service=" + serviceName + "/" + "version=" + version
+ + "/"
+ + "envContext=" + env + "/" + "partner=" + partner;
+ LoadPropertyFile.loadAFTProperties(latitude, longitude);
+ HashMap<String, String> hm = new HashMap<String, String>();
+ hm.put("AFT_DME2_EP_READ_TIMEOUT_MS", "50000");
+ hm.put("AFT_DME2_ROUNDTRIP_TIMEOUT_MS", "240000");
+ hm.put("AFT_DME2_EP_CONN_TIMEOUT", "5000");