diff options
Diffstat (limited to 'datarouter-node/src/main/java')
| -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 |