Merge pull request #16 from agorapulse/chore/force-run-java-friendly

more options for forceRun and run methods

build.gradle

@@ -101,6 +101,11 @@ config {
                 enabled = false
             }
         }
+        sourceHtml {
+            aggregate {
+                enabled = false
+            }
+        }
     }
 
 }

docs/guide/src/docs/asciidoc/index.adoc

@@ -20,5 +20,3 @@ include::{includedir}/usage.adoc[]
 = Links
 
 link:api/index.html[Javadoc, window="_blank"]
-
-link:api-html/index.html[Source, window="_blank"]

libs/micronaut-worker-queues-redis/src/test/groovy/com/agorapulse/worker/queues/redis/RedisQueuesSpec.groovy

@@ -21,8 +21,10 @@ import com.agorapulse.worker.tck.queue.AbstractQueuesSpec
 import io.micronaut.context.ApplicationContext
 import org.testcontainers.containers.GenericContainer
 import org.testcontainers.spock.Testcontainers
+import spock.lang.Retry
 import spock.lang.Shared
 
+@Retry
 @Testcontainers
 class RedisQueuesSpec extends AbstractQueuesSpec {
 

libs/micronaut-worker/src/main/java/com/agorapulse/worker/JobManager.java

@@ -25,6 +25,14 @@
 
 public interface JobManager {
 
+    static String getDefaultJobName(Class<?> jobClass) {
+        return NameUtils.hyphenate(jobClass.getSimpleName());
+    }
+
+    static String getDefaultJobName(Class<?> jobClass, String methodName) {
+        return NameUtils.hyphenate(jobClass.getSimpleName() + "-" + methodName);
+    }
+
     /**
      * Registers a new job.
      *
@@ -70,10 +78,22 @@ default void forceRun(String jobName) {
     void enqueue(String jobName, Object message);
 
     default void run(Class<?> jobClass) {
-        run(NameUtils.hyphenate(jobClass.getSimpleName()));
+        run(getDefaultJobName(jobClass));
+    }
+
+    default void run(Class<?> jobClass, String methodName) {
+        run(getDefaultJobName(jobClass, methodName));
+    }
+
+    default void forceRun(Class<?> jobClass) {
+        forceRun(getDefaultJobName(jobClass));
+    }
+
+    default void forceRun(Class<?> jobClass, String methodName) {
+        forceRun(getDefaultJobName(jobClass, methodName));
     }
 
     default <T> void enqueue(Class<? extends Consumer<? extends T>> jobClass, T message) {
-        enqueue(NameUtils.hyphenate(jobClass.getSimpleName()), message);
+        enqueue(getDefaultJobName(jobClass), message);
     }
 }

libs/micronaut-worker/src/main/java/com/agorapulse/worker/processor/MethodJobProcessor.java

@@ -154,10 +154,10 @@ private String getJobName(BeanDefinition<?> beanDefinition, ExecutableMethod<?,
 
         // there are more then one job definition
         if (beanDefinition.getExecutableMethods().size() > 1) {
-            return NameUtils.hyphenate(method.getDeclaringType().getSimpleName() + "-" + method.getMethodName());
+            return JobManager.getDefaultJobName(method.getDeclaringType(), method.getMethodName());
         }
 
-        return NameUtils.hyphenate(method.getDeclaringType().getSimpleName());
+        return JobManager.getDefaultJobName(method.getDeclaringType());
     }
 
     private JobConfiguration getJobConfiguration(BeanDefinition<?> beanDefinition, ExecutableMethod<?, ?> method) {