diff options
Diffstat (limited to 'services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java')
-rw-r--r-- | services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java | 31 |
1 files changed, 8 insertions, 23 deletions
diff --git a/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java b/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java index 14ca3f0fa..1167426e4 100644 --- a/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java +++ b/services/services-engine/src/main/java/org/onap/policy/apex/service/engine/event/PeeredReference.java @@ -1,32 +1,35 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2016-2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 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. - * + * * SPDX-License-Identifier: Apache-2.0 * ============LICENSE_END========================================================= */ package org.onap.policy.apex.service.engine.event; +import lombok.Getter; import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode; /** * This class holds a reference to an event consumer and producer that have been peered. - * + * * @author Liam Fallon (liam.fallon@ericsson.com) */ +@Getter public class PeeredReference { // The consumer putting events into APEX private final ApexEventConsumer peeredConsumer; @@ -36,7 +39,7 @@ public class PeeredReference { /** * Create a peered consumer/producer reference. - * + * * @param peeredMode the peered mode for which to return the reference * @param consumer the consumer that is receiving event * @param producer the producer that is sending events @@ -50,22 +53,4 @@ public class PeeredReference { peeredConsumer.setPeeredReference(peeredMode, this); peeredProducer.setPeeredReference(peeredMode, this); } - - /** - * Gets the synchronous consumer putting events into the cache. - * - * @return the source synchronous consumer - */ - public ApexEventConsumer getPeeredConsumer() { - return peeredConsumer; - } - - /** - * Gets the synchronous producer taking events from the cache. - * - * @return the synchronous producer that is taking events from the cache - */ - public ApexEventProducer getPeeredProducer() { - return peeredProducer; - } } |