diff options
author | HelenaLydon <helena.lydon@est.tech> | 2019-08-22 15:53:27 +0000 |
---|---|---|
committer | HelenaLydon <helena.lydon@est.tech> | 2019-08-22 15:53:27 +0000 |
commit | 8280a5e1a6cfd155edfafe882439b8c04c6a4509 (patch) | |
tree | 241b046a34ceb0e936f867334db01454998fccb6 /datarouter-node/src/main/java/org/onap | |
parent | 1c11dffada48c31491f2583f0d28ccecb4b4891b (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/org/onap')
-rw-r--r-- | datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/DeliveryQueue.java | 22 |
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 |