public class DeferResultInterceptor extends AbstractInterceptor<MessagingContainer> implements MessageEnvelopeInterceptor, Prototype<DeferResultInterceptor>
Extension.InitPriorityComparator, Extension.ShutdownPriorityComparator
Prototype.PrototypingContext
DEFAULT_INIT_PRIORITY, DEFAULT_SHUTDOWN_PRIORITY
Constructor and Description |
---|
DeferResultInterceptor() |
DeferResultInterceptor(Graph targetGraph) |
Modifier and Type | Method and Description |
---|---|
InterceptorResult |
after(MessageEnvelope messageEnvelope,
ExecutionContext executionContext,
ExecutionResult executionResult)
Run after a message envelope is executed.
|
InterceptorResult |
before(MessageEnvelope messageEnvelope,
ExecutionContext executionContext,
ExecutionResult executionResult)
Run before a message envelope is executed.
|
void |
exception(MessageEnvelope messageEnvelope,
ExecutionContext executionContext,
ExecutionResult executionResult,
Exception ex)
Run if an exception occurs while a message envelope is executed.
|
static Map<Message,Boolean> |
getDeferResults(ExecutionContext executionContext) |
Graph |
getTargetGraph() |
Graph |
getTargetGraph(ExecutionContext executionContext) |
static boolean |
hasDeferResult(ExecutionContext executionContext,
Message message) |
DeferResultInterceptor |
instanceFor(Prototype.PrototypingContext prototypingContext) |
static void |
putDeferResult(ExecutionContext executionContext,
Message message,
Boolean deferResult) |
void |
setTargetGraph(Graph targetGraph) |
clearDisabled, clearDisabledForMessage, clearDisabledForMessageEnvelope, clearDisabledForOperation, getInitPriority, getShutdownPriority, init, setDisabled, setDisabledForMessage, setDisabledForMessageEnvelope, setDisabledForOperation, shutdown, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearDisabled, clearDisabledForMessage, clearDisabledForMessageEnvelope, clearDisabledForOperation, getInitPriority, getShutdownPriority, init, setDisabled, setDisabledForMessage, setDisabledForMessageEnvelope, setDisabledForOperation, shutdown, skip
public DeferResultInterceptor(Graph targetGraph)
public DeferResultInterceptor()
public DeferResultInterceptor instanceFor(Prototype.PrototypingContext prototypingContext) throws Xdi2MessagingException
instanceFor
in interface Prototype<DeferResultInterceptor>
Xdi2MessagingException
public InterceptorResult before(MessageEnvelope messageEnvelope, ExecutionContext executionContext, ExecutionResult executionResult) throws Xdi2MessagingException
MessageEnvelopeInterceptor
before
in interface MessageEnvelopeInterceptor
messageEnvelope
- The message envelope to process.executionContext
- The current execution context.executionResult
- The executionResult.Xdi2MessagingException
public InterceptorResult after(MessageEnvelope messageEnvelope, ExecutionContext executionContext, ExecutionResult executionResult) throws Xdi2MessagingException
MessageEnvelopeInterceptor
after
in interface MessageEnvelopeInterceptor
messageEnvelope
- The message envelope to process.executionContext
- The current execution context.executionResult
- The executionResult.Xdi2MessagingException
public void exception(MessageEnvelope messageEnvelope, ExecutionContext executionContext, ExecutionResult executionResult, Exception ex)
MessageEnvelopeInterceptor
exception
in interface MessageEnvelopeInterceptor
executionContext
- The current execution context.executionResult
- The executionResult.ex
- The exception that occurred.public Graph getTargetGraph(ExecutionContext executionContext)
public Graph getTargetGraph()
public void setTargetGraph(Graph targetGraph)
public static Map<Message,Boolean> getDeferResults(ExecutionContext executionContext)
public static boolean hasDeferResult(ExecutionContext executionContext, Message message)
public static void putDeferResult(ExecutionContext executionContext, Message message, Boolean deferResult)
Copyright © 2017. All rights reserved.