Package | Description |
---|---|
com.atlassian.jira.cluster.distribution.localq | |
com.atlassian.jira.cluster.distribution.localq.rmi | |
com.atlassian.jira.cluster.distribution.localq.tape |
Modifier and Type | Method and Description |
---|---|
LocalQCacheOp |
LocalQCacheOpQueueWithStats.peek() |
LocalQCacheOp |
LocalQCacheOpQueue.peek()
Allows to see whats on the head of the queue without removing it
|
LocalQCacheOp |
LocalQCacheOpQueueWithStats.peekOrBlock() |
LocalQCacheOp |
LocalQCacheOpQueue.peekOrBlock()
see
LocalQCacheOpQueue.peek() but will block when the queue is empty; |
Modifier and Type | Method and Description |
---|---|
boolean |
LocalQCacheOpQueueWithStats.add(LocalQCacheOp localQCacheOp) |
boolean |
LocalQCacheOpQueue.add(LocalQCacheOp localQCacheOp)
transactional add of
LocalQCacheOp to the queue;
when operation finished we "guarantee" that the LocalQCacheOp is persisted |
int |
LocalQCacheManager.addToAllQueues(LocalQCacheOp localQCacheOp) |
boolean |
LocalQCriticalHandler.handleCriticalAdd(LocalQCacheOpQueue queue,
LocalQCacheOp toAdd,
Throwable t)
Should try to "somehow" solve the critical situation of adding on this queue, may retry adding to queue.
|
boolean |
LocalQCriticalHandler.handleCriticalRemove(LocalQCacheOpQueue queue,
LocalQCacheOp toRemove,
Throwable t)
Should try to "somehow" solve the critical situation of removing on this queue, may retry removing from queue.
|
void |
LocalQCacheOpSender.send(Node node,
LocalQCacheOp localQCacheOp)
If any
RuntimeException or LocalQCacheOpSender.UnrecoverableFailure is thrown LocalQCacheOp may never be send. |
Modifier and Type | Method and Description |
---|---|
void |
LocalQCacheOpRMISender.send(Node node,
LocalQCacheOp localQCacheOp) |
Modifier and Type | Method and Description |
---|---|
LocalQCacheOp |
TapeLocalQCacheOpConverter.from(byte[] bytes) |
LocalQCacheOp |
TapeLocalQCacheOpQueue.peek() |
LocalQCacheOp |
TapeLocalQCacheOpQueue.peekOrBlock() |
Modifier and Type | Method and Description |
---|---|
boolean |
TapeLocalQCacheOpQueue.add(LocalQCacheOp localQCacheOp) |
boolean |
TapeLocalQCriticalHandler.handleCriticalAdd(LocalQCacheOpQueue localQCacheOpQueue,
LocalQCacheOp toAdd,
Throwable t) |
boolean |
TapeLocalQCriticalHandler.handleCriticalRemove(LocalQCacheOpQueue localQCacheOpQueue,
LocalQCacheOp toRemove,
Throwable t) |
void |
TapeLocalQCacheOpConverter.toStream(LocalQCacheOp localQCacheOp,
OutputStream bytes) |
Copyright © 2002-2021 Atlassian. All Rights Reserved.