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.InterruptedExceptionpublic void acquire(LynxMessage message) throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void release(LynxMessage message) throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void lockAcquisitions()
public void throwOnLockAcquisitions(boolean shouldthrow)