3 * ========================LICENSE_START=================================
6 * Copyright (C) 2019 Nordix Foundation
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ========================LICENSE_END===================================
22 package org.oransc.policyagent.dmaap;
25 * The Dmaap consumer which has the base methods to be implemented by any class which implements this interface
28 public interface DmaapMessageConsumer {
31 * The init method creates the MRConsumer with the properties passed from the Application Config
38 * This method process the message and call the respective Controller
43 public abstract void processMsg(String msg) throws Exception;
46 * To check whether the DMAAP Listner is alive
50 public boolean isAlive();
53 * It's a infinite loop run every configured seconds to fetch the message from DMAAP. This method can be stop by
54 * setting the alive flag to false