aboutsummaryrefslogtreecommitdiffstats
path: root/datarouter-node/src/main/java
diff options
context:
space:
mode:
authorHelenaLydon <helena.lydon@est.tech>2019-08-22 15:53:27 +0000
committerHelenaLydon <helena.lydon@est.tech>2019-08-22 15:53:27 +0000
commit8280a5e1a6cfd155edfafe882439b8c04c6a4509 (patch)
tree241b046a34ceb0e936f867334db01454998fccb6 /datarouter-node/src/main/java
parent1c11dffada48c31491f2583f0d28ccecb4b4891b (diff)
DMAAP-1195 [DR] Remove DR code smells
Issue-ID: DMAAP-1195 Change-Id: I7c6117aa55d281fd0562c845a812107f9eb9581d Signed-off-by: HelenaLydon <helena.lydon@est.tech>
Diffstat (limited to 'datarouter-node/src/main/java')
-rw-r--r--datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java22
1 files changed, 11 insertions, 11 deletions
diff --git a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java
index e06ec5a8..4d336b73 100644
--- a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java
+++ b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java
@@ -83,6 +83,16 @@ public class DeliveryQueue implements Runnable, DeliveryTaskHelper {
private List<DeliveryTask> todoList = new ArrayList<>();
/**
+ * Create a delivery queue for a given destination info.
+ */
+ DeliveryQueue(DeliveryQueueHelper deliveryQueueHelper, DestInfo destinationInfo) {
+ this.deliveryQueueHelper = deliveryQueueHelper;
+ this.destinationInfo = destinationInfo;
+ dir = new File(destinationInfo.getSpool());
+ dir.mkdirs();
+ }
+
+ /**
* Try to cancel a delivery task.
*
* @return The length of the task in bytes or 0 if the task cannot be cancelled.
@@ -228,16 +238,6 @@ public class DeliveryQueue implements Runnable, DeliveryTaskHelper {
}
/**
- * Create a delivery queue for a given destination info.
- */
- DeliveryQueue(DeliveryQueueHelper deliveryQueueHelper, DestInfo destinationInfo) {
- this.deliveryQueueHelper = deliveryQueueHelper;
- this.destinationInfo = destinationInfo;
- dir = new File(destinationInfo.getSpool());
- dir.mkdirs();
- }
-
- /**
* Update the destination info for this delivery queue.
*/
public void config(DestInfo destinationInfo) {
@@ -449,4 +449,4 @@ public class DeliveryQueue implements Runnable, DeliveryTaskHelper {
}
return fname2;
}
-}
+} \ No newline at end of file