Package: AbstractProcessor

AbstractProcessor

name	instruction	branch	complexity	line	method
AbstractProcessor(String)	M: 5 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2016, 2020 Eurotech and/or its affiliates and others
3: *
4: * All rights reserved. This program and the accompanying materials
5: * are made available under the terms of the Eclipse Public License v1.0
6: * which accompanies this distribution, and is available at
7: * http://www.eclipse.org/legal/epl-v10.html
8: *
9: * Contributors:
10: * Eurotech - initial API and implementation
11: * Red Hat Inc
12: *******************************************************************************/
13: package org.eclipse.kapua.broker.core.listener;
14:
15: import org.eclipse.kapua.KapuaException;
16:
17: /**
18: * Default camel pojo endpoint processor.
19: *
20: * @param <M>
21: * Message to process
22: *
23: * @since 1.0
24: */
25: public abstract class AbstractProcessor<M> extends AbstractListener {
26:
27: /**
28: * Creates a processor with the specified name (used by component metrics name)
29: *
30: * @param name
31: */
32: protected AbstractProcessor(String name) {
33: super("processor", name);
34: }
35:
36: /**
37: * Process the incoming message
38: *
39: * @param message
40: * incoming message
41: * @throws KapuaException
42: */
43: public abstract void processMessage(M message) throws KapuaException;
44:
45: }