Package: DefaultData

DefaultData

name	instruction	branch	complexity	line	method
DefaultData(DefaultApplication, Topic)	M: 9 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 4 C: 0 0%	M: 1 C: 0 0%
send(Payload)	M: 7 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
static {...}	M: 4 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
subscribe(MessageHandler, ErrorHandler)	M: 19 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 4 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2017, 2022 Red Hat Inc and others.
3: *
4: * This program and the accompanying materials are made
5: * available under the terms of the Eclipse Public License 2.0
6: * which is available at https://www.eclipse.org/legal/epl-2.0/
7: *
8: * SPDX-License-Identifier: EPL-2.0
9: *
10: * Contributors:
11: * Red Hat Inc - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.client.gateway.spi;
14:
15: import java.util.Objects;
16: import java.util.concurrent.CompletionStage;
17:
18: import org.eclipse.kapua.client.gateway.Data;
19: import org.eclipse.kapua.client.gateway.ErrorHandler;
20: import org.eclipse.kapua.client.gateway.MessageHandler;
21: import org.eclipse.kapua.client.gateway.Payload;
22: import org.eclipse.kapua.client.gateway.Topic;
23: import org.slf4j.Logger;
24: import org.slf4j.LoggerFactory;
25:
26: public class DefaultData implements Data {
27:
28: private static final Logger logger = LoggerFactory.getLogger(DefaultData.class);
29:
30: private final DefaultApplication application;
31: private final Topic topic;
32:
33: public DefaultData(final DefaultApplication application, final Topic topic) {
34: this.application = application;
35: this.topic = topic;
36: }
37:
38: @Override
39: public CompletionStage<?> send(final Payload payload) {
40: return application.publish(topic, payload);
41: }
42:
43: @Override
44: public CompletionStage<?> subscribe(final MessageHandler handler, final ErrorHandler<? extends Throwable> errorHandler) throws Exception {
45: Objects.requireNonNull(handler);
46: Objects.requireNonNull(errorHandler);
47:
48: logger.debug("Setting subscription for: {}", topic);
49:
50: return application.subscribe(topic, handler, errorHandler);
51: }
52: }