Package | Description |
---|---|
com.neurosys.q.notification.events | |
com.neurosys.q.notification.service | |
com.neurosys.q.service |
Modifier and Type | Class and Description |
---|---|
class |
SynchronousTokenChangeListener<T extends Token<T>,CE extends TokenEvent<T>>
|
Modifier and Type | Interface and Description |
---|---|
interface |
ChildTokenEvent<T extends Token<T>>
An
IChild and a TokenEvent .A child event is defined as one that is generated as a result of another event known as the IChild.getParent() event. |
interface |
MultipleTokenEvent<T extends Token<T>> |
interface |
SingleTokenEvent<T extends Token<T>> |
interface |
SupplierTokenEvent<T extends Token<T>>
|
Modifier and Type | Class and Description |
---|---|
class |
BasicTokenEvent<T extends Token<T>>
Event over any
Token type. |
class |
MessageTokenEvent<T extends Token<T>>
A
BasicTokenEvent that also carries a message |
class |
NextTokenEvent<T extends Token<T>>
A
BasicTokenEvent that also factors in automation of next token(s) based on a post current action scenario
described by NextTokenEvent.nextTokensAction . |
Modifier and Type | Method and Description |
---|---|
TokenEvent<T> |
MessageTokenEvent.getParent()
The parent
TokenEvent that triggered this one |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
SynchronousTokenChangeEventSupplierBackedListener.onEventSupplierGenEvents(Supplier<List<PE>> eventsSupplier,
TokenEvent<T> change) |
protected void |
SynchronousTokenChangeEventSupplierBackedListener.onSynchChange(ChangeGenerator<TokenEvent<T>> changeGenerator,
TokenEvent<T> change) |
void |
MessageTokenEvent.setParent(TokenEvent<T> parent)
The parent
TokenEvent that triggered this one |
Modifier and Type | Method and Description |
---|---|
protected void |
SynchronousTokenChangeEventSupplierBackedListener.onSynchChange(ChangeGenerator<TokenEvent<T>> changeGenerator,
TokenEvent<T> change) |
Modifier and Type | Method and Description |
---|---|
Map |
AbstractNotificationHelper.addFeedback(TokenEvent<T> causeEvent,
FlowStatus status,
T token,
Feedback feedback)
Add Feedback
|
protected void |
AbstractTokenNotificationListener.dispatch(List<N> messages,
List<MessageTokenEvent<T>> events,
TokenEvent<T> parentEvent) |
protected void |
AbstractTokenNotificationListener.onEventSupplierGenEvents(Supplier<List<MessageTokenEvent<T>>> eventsSupplier,
TokenEvent<T> parentEvent) |
<E extends ChildTokenEvent<T>> |
AbstractNotificationHelper.setupNotificationEvent(TokenEvent<T> parentEvent,
E notifyCustomerEvent,
List<E> notifyEvents)
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTokenChangeGenerator<T extends Token<T>,E extends TokenEvent<T>> |
interface |
TokenGenerator<T extends Token<T>,R extends TokenRequest,E extends TokenEvent<T>>
Token request agent facing facade that generates tokens based on a
TokenRequest .In some setups the TokenGenerator maybe on a different machine like a phone etc.The TokenGenerator may be the same or consult a TokenDispatcher . |
interface |
TokenManager<T extends Token<T>,S extends Shift<T>,E extends TokenEvent<T>>
Manages the life cycle of the
Token and the interactions with the receiving part.The TokenManager maybe same or different from a TokenDispatcher in the sense that the Dispatcher is a centralized control system
while the Manager is the local manager of the Q in a de-centralized system. |
Modifier and Type | Method and Description |
---|---|
List<T> |
BatchService.add(B batch,
List<T> token,
Consumer<T> consumer,
TokenEvent<T> tokenEvent) |
List<T> |
TokenContainerService.add(C tokenContainer,
List<T> tokens,
Consumer<T> consumer,
TokenEvent<T> tokenEvent) |
List<T> |
TokenManager.add(S shift,
List<T> tokens,
TokenEvent<T> tokenEvent)
Assign tokens to a Shift
|
protected void |
DefaultAbstractTokenContainerService.notifyAllListeners(Supplier<Collection<T>> tokensSupplier,
TokenEvent<T> tokenEvent)
Convenience default method that allows basic mandatory actions like
fetching all the tokens and apply
AbstractTokenChangeGenerator.trackChange(Object) with asynchronous considerations |
List<T> |
TokenContainerService.remove(C tokenContainer,
List<T> tokens,
Consumer<T> consumer,
TokenEvent<T> tokenEvent)
Remove the association of the tokenContainer from the
Token |
List<T> |
TokenContainerService.update(C tokenContainer,
List<T> tokens,
TokenEvent<T> tokenEvent)
Update
Token s passed from an API which is untrusted. |
protected <S extends FlowStatus> |
DefaultAbstractTokenContainerService.updateStatus(C tokenContainer,
Collection c,
S status,
Function<String,javax.persistence.Query> query,
TokenEvent<T> tokenEvent) |
<S extends FlowStatus> |
TokenContainerService.updateStatus(C tokenContainer,
List tokens,
S status,
TokenEvent<T> tokenEvent)
Update collection of tokens with status
|
protected <S extends FlowStatus> |
DefaultAbstractTokenContainerService.updateStatus(Collection c,
S status,
Function<String,javax.persistence.Query> query,
TokenEvent<T> tokenEvent) |
<S extends FlowStatus> |
TokenContainerService.updateStatus(List tokens,
S status,
TokenEvent<T> tokenEvent)
Update collection of tokens with status
|
<STATUS extends FlowStatus> |
TokenManager.updateStatus(S shift,
List tokens,
STATUS status,
TokenEvent<T> tokenEvent)
Update collection of tokens with status
|
Copyright © 2018. All rights reserved.