}
@Override
- protected OfHeader buildRequest(final Xid xid, final SetRoleInput input) {
+ protected OfHeader buildRequest(final Xid xid, final SetRoleInput input) throws ServiceException {
return null;
}
currentRoleGuard.acquire();
LOG.trace("currentRole lock queue length: {} " + currentRoleGuard.getQueueLength());
} catch (final InterruptedException e) {
- LOG.error("Unexpected exception {} for acquire semaphor for input {}", e, input);
+ LOG.error("Unexpected exception {} for acquire semaphore for input {}", e, input);
return RpcResultBuilder.<SetRoleOutput> failed().buildFuture();
}
// compare with last known role and set if different. If they are same, then return.