1 /*******************************************************************************
2 * ============LICENSE_START==================================================
4 * * ===========================================================================
5 * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6 * * ===========================================================================
7 * * Licensed under the Apache License, Version 2.0 (the "License");
8 * * you may not use this file except in compliance with the License.
9 * * You may obtain a copy of the License at
11 * * http://www.apache.org/licenses/LICENSE-2.0
13 * * Unless required by applicable law or agreed to in writing, software
14 * * distributed under the License is distributed on an "AS IS" BASIS,
15 * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * * See the License for the specific language governing permissions and
17 * * limitations under the License.
18 * * ============LICENSE_END====================================================
20 * * ECOMP is a trademark and service mark of AT&T Intellectual Property.
22 ******************************************************************************/
25 package org.onap.dmaap.datarouter.node.delivery;
27 import org.onap.dmaap.datarouter.node.DestInfo;
30 * Interface to allow independent testing of the DeliveryQueue code
32 * <p>This interface represents all of the configuration information and
33 * feedback mechanisms that a delivery queue needs.
35 public interface DeliveryQueueHelper {
37 * Get the timeout (milliseconds) before retrying after an initial delivery failure.
39 long getInitFailureTimer();
42 * Get the timeout before retrying after delivery and wait for file processing.
44 long getWaitForFileProcessFailureTimer();
47 * Get the ratio between timeouts on consecutive delivery attempts.
49 double getFailureBackoff();
52 * Get the maximum timeout (milliseconds) between delivery attempts.
54 long getMaxFailureTimer();
57 * Get the expiration timer (milliseconds) for deliveries.
59 long getExpirationTimer();
62 * Get the maximum number of file delivery attempts before checking
63 * if another queue has work to be performed.
65 int getFairFileLimit();
68 * Get the maximum amount of time spent delivering files before checking if another queue has work to be performed.
70 long getFairTimeLimit();
73 * Get the URL for delivering a file.
75 * @param destinationInfo The destination information for the file to be delivered.
76 * @param fileid The file id for the file to be delivered.
77 * @return The URL for delivering the file (typically, destinationInfo.getURL() + "/" + fileid).
79 String getDestURL(DestInfo destinationInfo, String fileid);
82 * Forget redirections associated with a subscriber.
84 * @param destinationInfo Destination information to forget
86 void handleUnreachable(DestInfo destinationInfo);
89 * Post redirection for a subscriber.
91 * @param destinationInfo Destination information to update
92 * @param location Location given by subscriber
93 * @param fileid File ID of request
94 * @return true if this 3xx response is retryable, otherwise, false.
96 boolean handleRedirection(DestInfo destinationInfo, String location, String fileid);
99 * Should I handle 3xx responses differently than 4xx responses?.
101 boolean isFollowRedirects();
104 * Get the feed ID for a subscription.
106 * @param subid The subscription ID
107 * @return The feed ID
109 String getFeedId(String subid);