diff options
| -rw-r--r-- | src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java | 19 |
1 files changed, 3 insertions, 16 deletions
diff --git a/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java b/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java index 991c0e4..741705f 100644 --- a/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java +++ b/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java @@ -296,11 +296,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP props.getProperty("partition")); try { - /* - * final String contentType = fCompress ? - * MRFormat.CAMBRIA_ZIP.toString () : MRFormat.CAMBRIA.toString () ; - */ - + final ByteArrayOutputStream baseStream = new ByteArrayOutputStream(); OutputStream os = baseStream; final String contentType = props.getProperty("contenttype"); @@ -734,10 +730,6 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP private void DME2Configue() throws Exception { try { - /* - * FileReader reader = new FileReader(new File (producerFilePath)); - * Properties props = new Properties(); props.load(reader); - */ latitude = props.getProperty("Latitude"); longitude = props.getProperty("Longitude"); version = props.getProperty("Version"); @@ -746,12 +738,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP partner = props.getProperty("Partner"); routeOffer = props.getProperty("routeOffer"); subContextPath = props.getProperty("SubContextPath") + fTopic; - /* - * if(props.getProperty("partition")!=null && - * !props.getProperty("partition").equalsIgnoreCase("")){ - * subContextPath=subContextPath+"?partitionKey="+props.getProperty( - * "partition"); } - */ + protocol = props.getProperty("Protocol"); methodType = props.getProperty("MethodType"); dmeuser = props.getProperty("username"); @@ -794,7 +781,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP // SSL changes // System.setProperty("AFT_DME2_CLIENT_SSL_INCLUDE_PROTOCOLS", - // "SSLv3,TLSv1,TLSv1.1"); + System.setProperty("AFT_DME2_CLIENT_SSL_INCLUDE_PROTOCOLS", "TLSv1.1,TLSv1.2"); System.setProperty("AFT_DME2_CLIENT_IGNORE_SSL_CONFIG", "false"); System.setProperty("AFT_DME2_CLIENT_KEYSTORE_PASSWORD", "changeit"); |