Skip to content

Commit

Permalink
JavaDoc fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
gresrun committed Nov 6, 2015
1 parent e412d90 commit 2189b4b
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/main/java/net/greghaines/jesque/worker/Worker.java
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
* ...
* worker.end();
* t.join();
* </pre></p>
* </pre>
* @author Greg Haines
*/
public interface Worker extends JobExecutor, Runnable {
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/net/greghaines/jesque/worker/WorkerImpl.java
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ protected static void checkQueues(final Iterable<String> queues) {
private final JobFactory jobFactory;

/**
* Creates a new WorkerImpl, which creates it's own connection to Redis using values from the config.<br/>
* Creates a new WorkerImpl, which creates it's own connection to Redis using values from the config.<br>
* The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
* @param config used to create a connection to Redis and the package prefix for incoming jobs
* @param queues the list of queues to poll
Expand All @@ -134,7 +134,7 @@ public WorkerImpl(final Config config, final Collection<String> queues, final Jo
}

/**
* Creates a new WorkerImpl, with the given connection to Redis.<br/>
* Creates a new WorkerImpl, with the given connection to Redis.<br>
* The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
* @param config used to create a connection to Redis and the package prefix for incoming jobs
* @param queues the list of queues to poll
Expand Down Expand Up @@ -173,7 +173,7 @@ public long getWorkerId() {
}

/**
* Starts this worker. Registers the worker in Redis and begins polling the queues for jobs.<br/>
* Starts this worker. Registers the worker in Redis and begins polling the queues for jobs.<br>
* Stop this worker by calling end() on any thread.
*/
@Override
Expand Down Expand Up @@ -664,10 +664,10 @@ protected String failMsg(final Throwable thrwbl, final String queue, final Job j

/**
* Create and serialize a WorkerStatus.
* @param queuethe queue the Job came from
* @param queue the queue the Job came from
* @param job the Job currently being processed
* @return the JSON representation of a new WorkerStatus
* @throws IOExceptionif there was an error serializing the WorkerStatus
* @throws IOException if there was an error serializing the WorkerStatus
*/
protected String statusMsg(final String queue, final Job job) throws IOException {
final WorkerStatus status = new WorkerStatus();
Expand Down

0 comments on commit 2189b4b

Please sign in to comment.