| 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-2024 Atlassian. All Rights Reserved.