public class MessageKeyedLock
extends java.lang.Object
Constructor and Description |
---|
MessageKeyedLock(java.lang.String name) |
MessageKeyedLock(java.lang.String name,
int msAquisitionTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
acquire(LynxMessage message) |
void |
lockAcquisitions() |
void |
release(LynxMessage message) |
void |
reset() |
void |
throwOnLockAcquisitions(boolean shouldthrow) |
public MessageKeyedLock(java.lang.String name)
public MessageKeyedLock(java.lang.String name, int msAquisitionTimeout)
public void reset() throws java.lang.InterruptedException
java.lang.InterruptedException
public void acquire(LynxMessage message) throws java.lang.InterruptedException
java.lang.InterruptedException
public void release(LynxMessage message) throws java.lang.InterruptedException
java.lang.InterruptedException
public void lockAcquisitions()
public void throwOnLockAcquisitions(boolean shouldthrow)