Skip to content

Commit

Permalink
Publish guide for 2.2.0
Browse files Browse the repository at this point in the history
  • Loading branch information
runner committed Nov 13, 2024
1 parent 84393bb commit 597ecc0
Showing 1 changed file with 20 additions and 17 deletions.
37 changes: 20 additions & 17 deletions index.html
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@
<h1>Micronaut Worker</h1>
<div class="details">
<span id="author" class="author">Vladimir Orany</span><br>
<span id="revnumber">version 2.1.1</span>
<span id="revnumber">version 2.2.0</span>
</div>
<div id="toc" class="toc2">
<div id="toctitle">Table of Contents</div>
Expand Down Expand Up @@ -201,22 +201,22 @@ <h2 id="_installation_"><a class="anchor" href="#_installation_"></a>2. Installa
}

dependencies {
implementation 'com.agorapulse:micronaut-worker:2.1.1'
implementation 'com.agorapulse:micronaut-worker:2.2.0'

// to enable /jobs endpoint
implementation 'com.agorapulse:micronaut-worker-management:2.1.1'
implementation 'com.agorapulse:micronaut-worker-management:2.2.0'

// to enable AWS SDK v1 SQS queues integration
implementation 'com.agorapulse:micronaut-worker-queues-sqs-v1:2.1.1'
implementation 'com.agorapulse:micronaut-worker-queues-sqs-v1:2.2.0'

// to enable AWS SDK v2 SQS queues integration
implementation 'com.agorapulse:micronaut-worker-queues-sqs-v2:2.1.1'
implementation 'com.agorapulse:micronaut-worker-queues-sqs-v2:2.2.0'

// to enable Redis leader/follower capabilities
implementation 'com.agorapulse:micronaut-worker-executor-redis:2.1.1'
implementation 'com.agorapulse:micronaut-worker-executor-redis:2.2.0'

// to enable Redis queues integration
implementation 'com.agorapulse:micronaut-worker-queues-redis:2.1.1'
implementation 'com.agorapulse:micronaut-worker-queues-redis:2.2.0'

// you also need Redis configuration on the classpath depending on your Micronaut version
// for Micronaut 1.x
Expand Down Expand Up @@ -686,9 +686,9 @@ <h3 id="_events"><a class="anchor" href="#_events"></a>3.6. Events</h3>
void onJobExecutionStarted(JobExecutionStartedEvent event) {
if (LOGGER.isDebugEnabled()) {
if (event.getMessage().isPresent()) {
LOGGER.debug("Starting job {} with message {}", event.getName(), event.getMessage().get());
LOGGER.debug("Starting job {}#{} with message {}", event.getName(), event.getId(), event.getMessage().get());
} else {
LOGGER.debug("Starting job {}", event.getName());
LOGGER.debug("Starting job {}#{}", event.getName(), event.getId());
}
}
}
Expand All @@ -698,17 +698,17 @@ <h3 id="_events"><a class="anchor" href="#_events"></a>3.6. Events</h3>
if (LOGGER.isDebugEnabled()) {
Object result = event.getResult();
if (result != null) {
LOGGER.debug("Job {} emitted result {}", event.getName(), result);
LOGGER.debug("Job {}#{} emitted result {}", event.getName(), event.getId(), result);
} else if (LOGGER.isTraceEnabled()){
LOGGER.trace("No results emitted from job {}", event.getName());
LOGGER.trace("No results emitted from job {}#{}", event.getName(), event.getId());
}
}
}

@EventListener
void onJobExecutionFinished(JobExecutionFinishedEvent event) {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Finished executing job {} (some results can still be generated asynchronously later)", event.getName());
LOGGER.debug("Finished executing job {}#{} in {} (some results can still be generated asynchronously later)", event.getName(), event.getStatus().getId(), event.getStatus().getDuration());
}
}

Expand Down Expand Up @@ -764,7 +764,8 @@ <h3 id="_management"><a class="anchor" href="#_management"></a>3.7. Management</
"lastFinished": null,
"lastDuration": null,
"lastException": null,
"name": "sample-job"
"name": "sample-job",
"lastId": null
},
"source": "method com.agorapulse.worker.management.SampleJob#run",
"name": "sample-job"
Expand Down Expand Up @@ -859,7 +860,8 @@ <h3 id="_console_integration"><a class="anchor" href="#_console_integration"></a
"lastFinished": null,
"lastDuration": null,
"lastException": null,
"name": "sample-job"
"name": "sample-job",
"lastId": null
},
"source": "method com.agorapulse.worker.console.SampleJob#run",
"name": "sample-job"
Expand Down Expand Up @@ -918,7 +920,8 @@ <h3 id="_console_integration"><a class="anchor" href="#_console_integration"></a
"lastFinished": null,
"lastDuration": null,
"lastException": null,
"name": "sample-job"
"name": "sample-job",
"lastId": null
},
"source": "method com.agorapulse.worker.console.SampleJob#run",
"name": "sample-job"
Expand All @@ -940,8 +943,8 @@ <h2 id="_links"><a class="anchor" href="#_links"></a>4. Links</h2>
</div>
<div id="footer">
<div id="footer-text">
Version 2.1.1<br>
Last updated 2024-11-12 11:30:09 UTC
Version 2.2.0<br>
Last updated 2024-11-13 14:24:03 UTC
</div>
</div>
<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/prettify/r298/prettify.min.css">
Expand Down

0 comments on commit 597ecc0

Please sign in to comment.