diff options
Diffstat (limited to 'src/main/java/com/att/nsa/mr/client')
| -rw-r--r-- | src/main/java/com/att/nsa/mr/client/MRClientFactory.java | 6 | ||||
| -rw-r--r-- | src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java | 1 |
2 files changed, 6 insertions, 1 deletions
diff --git a/src/main/java/com/att/nsa/mr/client/MRClientFactory.java b/src/main/java/com/att/nsa/mr/client/MRClientFactory.java index 97aa0b8..a51e7eb 100644 --- a/src/main/java/com/att/nsa/mr/client/MRClientFactory.java +++ b/src/main/java/com/att/nsa/mr/client/MRClientFactory.java @@ -657,11 +657,13 @@ public class MRClientFactory { sub.setUsername(props.getProperty("username")); sub.setPassword(props.getProperty("password")); } - sub.setRouterFilePath(props.getProperty("DME2preferredRouterFilePath")); + sub.setProps(props); sub.setHost(props.getProperty("host")); sub.setProtocolFlag(props.getProperty("TransportType")); sub.setfFilter(props.getProperty("filter")); + if (props.getProperty("TransportType").equalsIgnoreCase(ProtocolTypeConstants.DME2.getValue())) { + sub.setRouterFilePath(props.getProperty("DME2preferredRouterFilePath")); routeFilePath = props.getProperty("DME2preferredRouterFilePath"); routeReader = new FileReader(new File(routeFilePath)); prop = new Properties(); @@ -669,6 +671,8 @@ public class MRClientFactory { if (!fo.exists()) { routeWriter = new FileWriter(new File(routeFilePath)); } + } + return sub; } } 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 8509042..4f44d30 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 @@ -864,6 +864,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP send(false); } }, 100, threadOccuranceTime, TimeUnit.MILLISECONDS); + pubResponse = new MRPublisherResponse(); } private static class TimestampedMessage extends message { |