Skip to content

Commit e183217

Browse files
tiagodolphinergdoliveira
authored andcommitted
[KOGITO-9816] Adding ProcessDefinitionRegistration to springboot (apache#3310)
* KOGITO-9816 adding ProcessDefinitionRegistration to springboot
1 parent e9d2e45 commit e183217

File tree

2 files changed

+46
-3
lines changed

2 files changed

+46
-3
lines changed

springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,9 +75,7 @@ public void publish(DataEvent<?> event) {
7575
publishToTopic(event, USER_TASK_INSTANCES_TOPIC_NAME);
7676
break;
7777
case "ProcessDefinitionEvent":
78-
if (processDefinitionEvents) {
79-
publishToTopic(event, PROCESS_DEFINITIONS_TOPIC_NAME);
80-
}
78+
publishToTopic(event, PROCESS_DEFINITIONS_TOPIC_NAME);
8179
break;
8280
default:
8381
logger.debug("Unknown type of event '{}', ignoring for this publisher", event.getType());
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.kie.kogito.process;
20+
21+
import org.kie.kogito.Application;
22+
import org.kie.kogito.services.registry.ProcessDefinitionEventRegistry;
23+
import org.springframework.beans.factory.InitializingBean;
24+
import org.springframework.beans.factory.annotation.Autowired;
25+
import org.springframework.beans.factory.annotation.Value;
26+
import org.springframework.stereotype.Component;
27+
28+
@Component
29+
public class ProcessDefinitionRegistration implements InitializingBean {
30+
Processes processes;
31+
ProcessDefinitionEventRegistry processDefinitionRegistry;
32+
33+
@Autowired
34+
public ProcessDefinitionRegistration(Application application, @Value("kogito.service.url") String serviceUrl, @Autowired(required = false) Processes processes) {
35+
this.processes = processes;
36+
this.processDefinitionRegistry = new ProcessDefinitionEventRegistry(application, serviceUrl);
37+
}
38+
39+
@Override
40+
public void afterPropertiesSet() {
41+
if (processes != null) {
42+
processDefinitionRegistry.register(processes);
43+
}
44+
}
45+
}

0 commit comments

Comments
 (0)