Skip to content

Commit

Permalink
Fix indentation
Browse files Browse the repository at this point in the history
  • Loading branch information
lpfeup committed Jun 22, 2018
1 parent ecad17b commit 8b832a3
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions src/main/java/net/greghaines/jesque/worker/WorkerImpl.java
Original file line number Diff line number Diff line change
Expand Up @@ -537,10 +537,10 @@ protected void recoverFromException(final String curQueue, final Exception ex) {
authenticateAndSelectDB();
LOG.info("Reconnected to Redis");
try {
loadRedisScripts();
} catch (IOException e) {
LOG.error("Failed to load redis scripts", e);
}
loadRedisScripts();
} catch (IOException e) {
LOG.error("Failed to load redis scripts", e);
}
}
break;
case TERMINATE:
Expand Down Expand Up @@ -797,12 +797,12 @@ protected String lpoplpush(final String from, final String to) {
return (String) this.jedis.evalsha(this.lpoplpushScriptHash.get(), 2, from, to);
}

private void loadRedisScripts() throws IOException {
this.popScriptHash.set(this.jedis.scriptLoad(ScriptUtils.readScript(POP_LUA)));
this.lpoplpushScriptHash.set(this.jedis.scriptLoad(ScriptUtils.readScript(LPOPLPUSH_LUA)));
this.multiPriorityQueuesScriptHash
.set(this.jedis.scriptLoad(ScriptUtils.readScript(POP_FROM_MULTIPLE_PRIO_QUEUES)));
}
private void loadRedisScripts() throws IOException {
this.popScriptHash.set(this.jedis.scriptLoad(ScriptUtils.readScript(POP_LUA)));
this.lpoplpushScriptHash.set(this.jedis.scriptLoad(ScriptUtils.readScript(LPOPLPUSH_LUA)));
this.multiPriorityQueuesScriptHash
.set(this.jedis.scriptLoad(ScriptUtils.readScript(POP_FROM_MULTIPLE_PRIO_QUEUES)));
}

/**
* {@inheritDoc}
Expand Down

0 comments on commit 8b832a3

Please sign in to comment.