X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=datarouter-node%2Fsrc%2Fmain%2Fjava%2Fcom%2Fatt%2Fresearch%2Fdatarouter%2Fnode%2FDeliveryQueueHelper.java;fp=datarouter-node%2Fsrc%2Fmain%2Fjava%2Fcom%2Fatt%2Fresearch%2Fdatarouter%2Fnode%2FDeliveryQueueHelper.java;h=770db1dc4ccb98e7696b1080f31f4e39bcce3c2f;hb=aaf2df8b908fcb48043d2cd51803d8fd99f18b43;hp=0000000000000000000000000000000000000000;hpb=6ec9a9ce6c1062efa99da501fe8c6ea116aebf6f;p=dmaap%2Fdatarouter.git

diff --git a/datarouter-node/src/main/java/com/att/research/datarouter/node/DeliveryQueueHelper.java b/datarouter-node/src/main/java/com/att/research/datarouter/node/DeliveryQueueHelper.java
new file mode 100644
index 00000000..770db1dc
--- /dev/null
+++ b/datarouter-node/src/main/java/com/att/research/datarouter/node/DeliveryQueueHelper.java
@@ -0,0 +1,89 @@
+/*******************************************************************************
+ * ============LICENSE_START==================================================
+ * * org.onap.dmaap
+ * * ===========================================================================
+ * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * * ===========================================================================
+ * * Licensed under the Apache License, Version 2.0 (the "License");
+ * * you may not use this file except in compliance with the License.
+ * * You may obtain a copy of the License at
+ * * 
+ *  *      http://www.apache.org/licenses/LICENSE-2.0
+ * * 
+ *  * Unless required by applicable law or agreed to in writing, software
+ * * distributed under the License is distributed on an "AS IS" BASIS,
+ * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * * See the License for the specific language governing permissions and
+ * * limitations under the License.
+ * * ============LICENSE_END====================================================
+ * *
+ * * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ * *
+ ******************************************************************************/
+
+
+package com.att.research.datarouter.node;
+
+/**
+ *	Interface to allow independent testing of the DeliveryQueue code
+ *	<p>
+ *	This interface represents all of the configuration information and
+ *	feedback mechanisms that a delivery queue needs.
+ */
+public interface	DeliveryQueueHelper	{
+	/**
+	 *	Get the timeout (milliseconds) before retrying after an initial delivery failure
+	 */
+	public long getInitFailureTimer();
+	/**
+	 *	Get the ratio between timeouts on consecutive delivery attempts
+	 */
+	public double	getFailureBackoff();
+	/**
+	 *	Get the maximum timeout (milliseconds) between delivery attempts
+	 */
+	public long	getMaxFailureTimer();
+	/**
+	 *	Get the expiration timer (milliseconds) for deliveries
+	 */
+	public long	getExpirationTimer();
+	/**
+	 *	Get the maximum number of file delivery attempts before checking
+	 *	if another queue has work to be performed.
+	 */
+	public int getFairFileLimit();
+	/**
+	 *	Get the maximum amount of time spent delivering files before checking if another queue has work to be performed.
+	 */
+	public long getFairTimeLimit();
+	/**
+	 *	Get the URL for delivering a file
+	 *	@param dest	The destination information for the file to be delivered.
+	 *	@param fileid	The file id for the file to be delivered.
+	 *	@return	The URL for delivering the file (typically, dest.getURL() + "/" + fileid).
+	 */
+	public String	getDestURL(DestInfo dest, String fileid);
+	/**
+	 *	Forget redirections associated with a subscriber
+	 *	@param	dest	Destination information to forget
+	 */
+	public void	handleUnreachable(DestInfo dest);
+	/**
+	 *	Post redirection for a subscriber
+	 *	@param	dest	Destination information to update
+	 *	@param	location	Location given by subscriber
+	 *	@param	fileid	File ID of request
+	 *	@return	true if this 3xx response is retryable, otherwise, false.
+	 */
+	public boolean	handleRedirection(DestInfo dest, String location, String fileid);
+	/**
+	 *	Should I handle 3xx responses differently than 4xx responses?
+	 */
+	public boolean	isFollowRedirects();
+	/**
+	 *	Get the feed ID for a subscription
+	 *	@param subid	The subscription ID
+	 *	@return	The feed ID
+	 */
+	public String getFeedId(String subid);
+}