![[Jenkins]](/kapua/static/dff81f37/images/svgs/logo.svg){kind=logo}
Package: TriggerCreatorImpl
TriggerCreatorImpl
| name | instruction | branch | complexity | line | method | ||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| TriggerCreatorImpl(KapuaId, String) |
|
|
|
|
|
||||||||||||||||||||
| getCronScheduling() |
|
|
|
|
|
||||||||||||||||||||
| getEndsOn() |
|
|
|
|
|
||||||||||||||||||||
| getRetryInterval() |
|
|
|
|
|
||||||||||||||||||||
| getStartsOn() |
|
|
|
|
|
||||||||||||||||||||
| getTriggerDefinitionId() |
|
|
|
|
|
||||||||||||||||||||
| getTriggerProperties() |
|
|
|
|
|
||||||||||||||||||||
| getTriggerProperty(String) |
|
|
|
|
|
||||||||||||||||||||
| lambda$getTriggerProperty$0(String, TriggerProperty) |
|
|
|
|
|
||||||||||||||||||||
| setCronScheduling(String) |
|
|
|
|
|
||||||||||||||||||||
| setEndsOn(Date) |
|
|
|
|
|
||||||||||||||||||||
| setRetryInterval(Long) |
|
|
|
|
|
||||||||||||||||||||
| setStartsOn(Date) |
|
|
|
|
|
||||||||||||||||||||
| setTriggerDefinitionId(KapuaId) |
|
|
|
|
|
||||||||||||||||||||
| setTriggerProperties(List) |
|
|
|
|
|
||||||||||||||||||||
Coverage
1: /*******************************************************************************
2: * Copyright (c) 2017, 2022 Eurotech and/or its affiliates 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: * Eurotech - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.service.scheduler.trigger.quartz;
14:
15: import org.eclipse.kapua.commons.model.AbstractKapuaNamedEntityCreator;
16: import org.eclipse.kapua.model.id.KapuaId;
17: import org.eclipse.kapua.service.scheduler.trigger.Trigger;
18: import org.eclipse.kapua.service.scheduler.trigger.TriggerCreator;
19: import org.eclipse.kapua.service.scheduler.trigger.definition.TriggerProperty;
20:
21: import java.util.ArrayList;
22: import java.util.Date;
23: import java.util.List;
24:
25: /**
26: * {@link TriggerCreator} implementation.
27: *
28: * @since 1.0.0
29: */
30: public class TriggerCreatorImpl extends AbstractKapuaNamedEntityCreator<Trigger> implements TriggerCreator {
31:
32: private static final long serialVersionUID = -2460883485294616032L;
33:
34: private Date startsOn;
35: private Date endsOn;
36: private String cronScheduling;
37: private Long retryInterval;
38: private KapuaId triggerDefinitionId;
39: private List<TriggerProperty> triggerProperties;
40:
41: /**
42: * Constructor.
43: *
44: * @param scopeId The scope {@link KapuaId}.
45: * @param name The name.
46: * @since 1.0.0
47: */
48: public TriggerCreatorImpl(KapuaId scopeId, String name) {
49: super(scopeId, name);
50: }
51:
52: @Override
53: public Date getStartsOn() {
54: return startsOn;
55: }
56:
57: @Override
58: public void setStartsOn(Date startsOn) {
59: this.startsOn = startsOn;
60: }
61:
62: @Override
63: public Date getEndsOn() {
64: return endsOn;
65: }
66:
67: @Override
68: public void setEndsOn(Date endsOn) {
69: this.endsOn = endsOn;
70: }
71:
72: @Override
73: public String getCronScheduling() {
74: return cronScheduling;
75: }
76:
77: @Override
78: public void setCronScheduling(String cronScheduling) {
79: this.cronScheduling = cronScheduling;
80: }
81:
82: @Override
83: public Long getRetryInterval() {
84: return retryInterval;
85: }
86:
87: @Override
88: public void setRetryInterval(Long retryInterval) {
89: this.retryInterval = retryInterval;
90: }
91:
92: @Override
93: public KapuaId getTriggerDefinitionId() {
94: return triggerDefinitionId;
95: }
96:
97: @Override
98: public void setTriggerDefinitionId(KapuaId triggerDefinitionId) {
99: this.triggerDefinitionId = triggerDefinitionId;
100: }
101:
102: @Override
103: public List<TriggerProperty> getTriggerProperties() {
104:• if (triggerProperties == null) {
105: triggerProperties = new ArrayList<>();
106: }
107:
108: return triggerProperties;
109: }
110:
111: @Override
112: public TriggerProperty getTriggerProperty(String name) {
113: return getTriggerProperties().stream().filter(tp -> tp.getName().equals(name)).findAny().orElse(null);
114: }
115:
116: @Override
117: public void setTriggerProperties(List<TriggerProperty> triggerProperties) {
118: this.triggerProperties = triggerProperties;
119: }
120:
121: }