public class SynchronizedPropagationList extends Object implements PropagationList
Modifier and Type | Class and Description |
---|---|
static class |
SynchronizedPropagationList.PropagationEntryIterator |
Modifier and Type | Field and Description |
---|---|
protected PropagationEntry |
head |
protected static org.slf4j.Logger |
log |
protected PropagationEntry |
tail |
protected InternalWorkingMemory |
workingMemory |
Constructor and Description |
---|
SynchronizedPropagationList(InternalWorkingMemory workingMemory) |
Modifier and Type | Method and Description |
---|---|
void |
addEntry(PropagationEntry entry) |
void |
flush() |
void |
flush(InternalWorkingMemory workingMemory,
PropagationEntry currentHead) |
void |
flush(PropagationEntry currentHead) |
boolean |
hasEntriesDeferringExpiration() |
protected void |
internalAddEntry(PropagationEntry entry) |
boolean |
isEmpty() |
Iterator<PropagationEntry> |
iterator() |
void |
notifyWaitOnRest() |
void |
onEngineInactive() |
void |
reset() |
PropagationEntry |
takeAll() |
void |
waitOnRest() |
protected static final transient org.slf4j.Logger log
protected final InternalWorkingMemory workingMemory
protected volatile PropagationEntry head
protected volatile PropagationEntry tail
public SynchronizedPropagationList(InternalWorkingMemory workingMemory)
public void addEntry(PropagationEntry entry)
addEntry
in interface PropagationList
protected void internalAddEntry(PropagationEntry entry)
public void flush()
flush
in interface PropagationList
public void flush(PropagationEntry currentHead)
flush
in interface PropagationList
public void flush(InternalWorkingMemory workingMemory, PropagationEntry currentHead)
public boolean hasEntriesDeferringExpiration()
hasEntriesDeferringExpiration
in interface PropagationList
public PropagationEntry takeAll()
takeAll
in interface PropagationList
public void reset()
reset
in interface PropagationList
public boolean isEmpty()
isEmpty
in interface PropagationList
public void waitOnRest()
waitOnRest
in interface PropagationList
public void notifyWaitOnRest()
notifyWaitOnRest
in interface PropagationList
public Iterator<PropagationEntry> iterator()
iterator
in interface PropagationList
public void onEngineInactive()
onEngineInactive
in interface PropagationList
Copyright © 2001–2017 JBoss by Red Hat. All rights reserved.