JobRunr event externalization.

Author: odrotbohm

etc/mappings.txt

@@ -4,6 +4,7 @@ cute=Cute
 flapdoodle-mongodb=Flapdoodle MongoDB
 jgit=jGit
 jmolecules-bom=jMolecules
+jobrunr=JobRunr
 json-unit-assertj=JSON Unit AssertJ
 lombok=Lombok
 micrometer-tracing=Micrometer Tracing

pom.xml

@@ -43,6 +43,7 @@
 		<flapdoodle-mongodb.version>4.20.0</flapdoodle-mongodb.version>
 		<jgit.version>7.6.0.202603022253-r</jgit.version>
 		<jmolecules-bom.version>2025.0.2</jmolecules-bom.version>
+		<jobrunr.version>8.5.1</jobrunr.version>
 		<json-unit-assertj.version>5.1.1</json-unit-assertj.version>
 		<namastack-outbox.version>1.1.1</namastack-outbox.version>
 		<nullaway.version>0.13.0</nullaway.version>

spring-modulith-bom/pom.xml

@@ -74,6 +74,11 @@
 				<artifactId>spring-modulith-events-jms</artifactId>
 				<version>2.1.0-SNAPSHOT</version>
 			</dependency>
+			<dependency>
+				<groupId>org.springframework.modulith</groupId>
+				<artifactId>spring-modulith-events-jobrunr</artifactId>
+				<version>2.1.0-SNAPSHOT</version>
+			</dependency>
 			<dependency>
 				<groupId>org.springframework.modulith</groupId>
 				<artifactId>spring-modulith-events-jpa</artifactId>
@@ -154,6 +159,11 @@
 				<artifactId>spring-modulith-starter-jpa</artifactId>
 				<version>2.1.0-SNAPSHOT</version>
 			</dependency>
+			<dependency>
+				<groupId>org.springframework.modulith</groupId>
+				<artifactId>spring-modulith-starter-jobrunr</artifactId>
+				<version>2.1.0-SNAPSHOT</version>
+			</dependency>
 			<dependency>
 				<groupId>org.springframework.modulith</groupId>
 				<artifactId>spring-modulith-starter-mongodb</artifactId>

spring-modulith-events/pom.xml

@@ -26,6 +26,7 @@
 		<module>spring-modulith-events-mongodb</module>
 		<module>spring-modulith-events-neo4j</module>
 		<module>spring-modulith-events-namastack</module>
+		<module>spring-modulith-events-jobrunr</module>
 	</modules>
 
 	<profiles>

spring-modulith-events/spring-modulith-events-jms/pom.xml

@@ -43,7 +43,7 @@
 
 		<dependency>
 			<groupId>org.springframework.modulith</groupId>
-			<artifactId>spring-modulith-events-namastack</artifactId>
+			<artifactId>spring-modulith-events-jobrunr</artifactId>
 			<version>${project.version}</version>
 			<optional>true</optional>
 		</dependency>

spring-modulith-events/spring-modulith-events-jms/src/main/java/org/springframework/modulith/events/jms/JmsEventExternalizerConfiguration.java

@@ -36,6 +36,7 @@
 import org.springframework.modulith.events.RoutingTarget;
 import org.springframework.modulith.events.config.EventExternalizationAutoConfiguration;
 import org.springframework.modulith.events.core.EventSerializer;
+import org.springframework.modulith.events.jobrunr.JobRunrExternalizationTransport;
 import org.springframework.modulith.events.support.BrokerRouting;
 import org.springframework.modulith.events.support.DelegatingEventExternalizer;
 import org.springframework.modulith.events.support.OutboxEventExternalizer;
@@ -85,6 +86,24 @@ OutboxHandler jmsOutboxExternalizer(EventExternalizationConfiguration configurat
 		}
 	}
 
+	@AutoConfiguration
+	@ConditionalOnClass(JobRunrExternalizationTransport.class)
+	static class JobRunrOutboxAutoConfiguration {
+
+		@Bean
+		@ConditionalOnProperty(name = ExternalizationMode.PROPERTY, havingValue = "outbox")
+		JobRunrExternalizationTransport jmsOutboxExternalizer(EventExternalizationConfiguration configuration,
+				JmsOperations operations, EventSerializer serializer, BeanFactory factory) {
+
+			logger.debug("Registering domain event outbox externalization to JMS…");
+
+			var externalizer = new OutboxEventExternalizer(configuration,
+					createJmsTransport(operations, serializer, factory));
+
+			return (event) -> externalizer.handle(event);
+		}
+	}
+
 	private static BiFunction<RoutingTarget, Object, CompletableFuture<?>> createJmsTransport(
 			JmsOperations operations, EventSerializer serializer, BeanFactory factory) {
 

spring-modulith-events/spring-modulith-events-jobrunr/pom.xml

@@ -0,0 +1,51 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>org.springframework.modulith</groupId>
+		<artifactId>spring-modulith-events</artifactId>
+		<version>2.1.0-SNAPSHOT</version>
+	</parent>
+	<artifactId>spring-modulith-events-jobrunr</artifactId>
+	<name>Spring Modulith - Events - JobRunr</name>
+
+	<properties>
+		<module.name>spring.modulith.events.jobrunr</module.name>
+	</properties>
+
+	<dependencies>
+	
+		<dependency>
+			<groupId>org.springframework.modulith</groupId>
+			<artifactId>spring-modulith-events-core</artifactId>
+			<version>${project.version}</version>
+		</dependency>
+	
+		<dependency>
+			<groupId>org.jobrunr</groupId>
+			<artifactId>jobrunr</artifactId>
+			<version>${jobrunr.version}</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>tools.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.awaitility</groupId>
+			<artifactId>awaitility</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+	</dependencies>
+
+</project>

spring-modulith-events/spring-modulith-events-jobrunr/src/main/java/org/springframework/modulith/events/jobrunr/JobRunrEventExternalizationAutoConfiguration.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2026 the original author or authors.
+ *
+ * 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
+ *
+ *      https://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.
+ */
+package org.springframework.modulith.events.jobrunr;
+
+import java.util.List;
+
+import org.jobrunr.scheduling.JobScheduler;
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.modulith.events.EventExternalizationConfiguration;
+import org.springframework.modulith.events.ExternalizationMode;
+import org.springframework.modulith.events.config.EventExternalizationAutoConfiguration;
+
+/**
+ * @author Oliver Drotbohm
+ */
+
+@AutoConfiguration
+@AutoConfigureAfter(EventExternalizationAutoConfiguration.class)
+@ConditionalOnProperty(name = ExternalizationMode.PROPERTY, havingValue = "outbox")
+@ConditionalOnProperty(name = "spring.modulith.events.externalization.enabled",
+		havingValue = "true",
+		matchIfMissing = true)
+@ConditionalOnBean(JobScheduler.class)
+class JobRunrEventExternalizationAutoConfiguration {
+
+	@Bean
+	JobRunrEventExternalizer jobRunrEventExternalizer(JobScheduler scheduler,
+			List<JobRunrExternalizationTransport> transports, EventExternalizationConfiguration configuration) {
+		return new JobRunrEventExternalizer(scheduler, transports, configuration);
+	}
+}

spring-modulith-events/spring-modulith-events-jobrunr/src/main/java/org/springframework/modulith/events/jobrunr/JobRunrEventExternalizer.java

@@ -0,0 +1,77 @@
+/*
+ * Copyright 2026 the original author or authors.
+ *
+ * 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
+ *
+ *      https://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.
+ */
+package org.springframework.modulith.events.jobrunr;
+
+import java.util.List;
+
+import org.jobrunr.scheduling.JobScheduler;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.PayloadApplicationEvent;
+import org.springframework.modulith.events.EventExternalizationConfiguration;
+import org.springframework.modulith.events.core.ConditionalEventListener;
+import org.springframework.util.Assert;
+
+/**
+ * @author Oliver Drotbohm
+ */
+class JobRunrEventExternalizer
+		implements ApplicationListener<PayloadApplicationEvent<?>>, ConditionalEventListener {
+
+	private final JobScheduler scheduler;
+	private final List<JobRunrExternalizationTransport> externalizers;
+	private final EventExternalizationConfiguration configuration;
+
+	/**
+	 * Creates a new {@link JobRunrEventExternalizer} for the given {@link JobScheduler},
+	 * {@link JobRunrExternalizationTransport}s and {@link EventExternalizationConfiguration}.
+	 *
+	 * @param scheduler must not be {@literal null}.
+	 * @param externalizers must not be {@literal null}.
+	 * @param configuration must not be {@literal null}.
+	 */
+	JobRunrEventExternalizer(JobScheduler scheduler, List<JobRunrExternalizationTransport> externalizers,
+			EventExternalizationConfiguration configuration) {
+
+		Assert.notNull(scheduler, "JobScheduler must not be null!");
+		Assert.notNull(externalizers, "JobRunrExternalizationTransports must not be null!");
+		Assert.notNull(configuration, "EventExternalizationConfiguration must not be null!");
+
+		this.scheduler = scheduler;
+		this.externalizers = externalizers;
+		this.configuration = configuration;
+	}
+
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.modulith.events.core.ConditionalEventListener#supports(java.lang.Object)
+	 */
+	@Override
+	public boolean supports(Object event) {
+		return configuration.supports(event);
+	}
+
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.context.ApplicationListener#onApplicationEvent(org.springframework.context.ApplicationEvent)
+	 */
+	@Override
+	public void onApplicationEvent(PayloadApplicationEvent<?> event) {
+
+		var payload = event.getPayload();
+
+		scheduler.enqueue(externalizers.stream(), it -> it.externalize(payload));
+	}
+}

spring-modulith-events/spring-modulith-events-jobrunr/src/main/java/org/springframework/modulith/events/jobrunr/JobRunrExternalizationTransport.java

@@ -0,0 +1,24 @@
+/*
+ * Copyright 2026 the original author or authors.
+ *
+ * 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
+ *
+ *      https://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.
+ */
+package org.springframework.modulith.events.jobrunr;
+
+/**
+ * @author Oliver Drotbohm
+ */
+public interface JobRunrExternalizationTransport {
+
+	void externalize(Object event);
+}