nl.nn.ibistesttool

Class IbisDebuggerAdvice

java.lang.Object

nl.nn.ibistesttool.IbisDebuggerAdvice

All Implemented Interfaces:

EventListener, ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>, IXmlDebugger, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationListener<DebuggerStatusChangedEvent>

public class IbisDebuggerAdvice
extends Object
implements org.springframework.beans.factory.InitializingBean, ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>, org.springframework.context.ApplicationListener<DebuggerStatusChangedEvent>, IXmlDebugger

Author:

Jaco de Groot (jaco@dynasol.nl)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IbisDebuggerAdvice.ParallelSenderExecutorWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
IbisDebuggerAdvice()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
nl.nn.ibistesttool.ThreadDebugInfo	announceChildThread(Object owner, String correlationId)
void	cancelChildThread(nl.nn.ibistesttool.ThreadDebugInfo threadInfo)
SenderResult	debugBlockEnabledSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Object blockHandle, Message message, PipeLineSession session) Provides advice for IBlockEnabledSender.sendMessage(Object blockHandle, Message message, PipeLineSession session)
Object	debugParameterResolvedTo(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) Provides advice for Parameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)
PipeRunResult	debugPipeGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) Provides advice for CheckSemaphorePipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) CheckSemaphorePipeProcessor is just after InputOutputPipeProcessor, so it sees the effect of the replacements made by the latter.
PipeRunResult	debugPipeInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) Provides advice for InputOutputPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session)
PipeLineResult	debugPipeLineInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, String messageId, Message message, PipeLineSession session) Provides advice for CorePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession session, String firstPipe)
MessageOutputStream	debugProvideOutputStream(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLineSession session) Provides advice for IOutputStreamingSupport.provideOutputStream(PipeLineSession session, IForwardTarget next)
<M> M	debugReplyListenerInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, ICorrelatedPullingListener<M> listener, String correlationId, PipeLineSession pipeLineSession)
SenderResult	debugSenderGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session) Provides advice for CacheSenderWrapperProcessor.sendMessage(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)
SenderResult	debugSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession session) Provides advice for ISender.sendMessageOrThrow(Message message, PipeLineSession session)
PipeRunResult	debugStreamingSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession session, IForwardTarget next) Provides advice for IStreamingSender.sendMessage(Message message, PipeLineSession session, IForwardTarget next)
Object	debugThreadCreateStartEndAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Runnable runnable)
PipeRunResult	debugValidatorInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IValidator validator, Message message, PipeLineSession session, String messageRoot)
String	getCorrelationId(PipeLineSession session)
ContentHandler	inspectXml(PipeLineSession session, String label, ContentHandler contentHandler, BiConsumer<AutoCloseable,String> closeOnCloseRegister) Allow the debugger to see the XML stream.
boolean	isEnabled()
void	onApplicationEvent(DebuggerStatusChangedEvent event)
void	setEnabled(boolean enable)
Throwable	threadAborted(nl.nn.ibistesttool.ThreadDebugInfo ref, Throwable t)
<R> R	threadCreated(nl.nn.ibistesttool.ThreadDebugInfo ref, R request)
<R> R	threadEnded(nl.nn.ibistesttool.ThreadDebugInfo ref, R result)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.context.ApplicationListener

forPayload

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

IbisDebuggerAdvice

public IbisDebuggerAdvice()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

debugPipeLineInputOutputAbort

public PipeLineResult debugPipeLineInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                    PipeLine pipeLine,
                                                    String messageId,
                                                    Message message,
                                                    PipeLineSession session)
                                             throws Throwable

Provides advice for CorePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession session, String firstPipe)

Throws:

Throwable

debugPipeInputOutputAbort

public PipeRunResult debugPipeInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                               PipeLine pipeLine,
                                               IPipe pipe,
                                               Message message,
                                               PipeLineSession session)
                                        throws Throwable

Provides advice for InputOutputPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session)

Throws:

Throwable

debugPipeGetInputFrom

public PipeRunResult debugPipeGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                           PipeLine pipeLine,
                                           IPipe pipe,
                                           Message message,
                                           PipeLineSession session)
                                    throws Throwable

Provides advice for CheckSemaphorePipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) CheckSemaphorePipeProcessor is just after InputOutputPipeProcessor, so it sees the effect of the replacements made by the latter.

Throws:

Throwable

debugValidatorInputOutputAbort

public PipeRunResult debugValidatorInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                    PipeLine pipeLine,
                                                    IValidator validator,
                                                    Message message,
                                                    PipeLineSession session,
                                                    String messageRoot)
                                             throws Throwable

Throws:

Throwable

debugSenderInputOutputAbort

public SenderResult debugSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                Message message,
                                                PipeLineSession session)
                                         throws Throwable

Provides advice for ISender.sendMessageOrThrow(Message message, PipeLineSession session)

Throws:

Throwable

debugBlockEnabledSenderInputOutputAbort

public SenderResult debugBlockEnabledSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                            Object blockHandle,
                                                            Message message,
                                                            PipeLineSession session)
                                                     throws Throwable

Provides advice for IBlockEnabledSender.sendMessage(Object blockHandle, Message message, PipeLineSession session)

Throws:

Throwable

debugStreamingSenderInputOutputAbort

public PipeRunResult debugStreamingSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                          Message message,
                                                          PipeLineSession session,
                                                          IForwardTarget next)
                                                   throws Throwable

Provides advice for IStreamingSender.sendMessage(Message message, PipeLineSession session, IForwardTarget next)

Throws:

Throwable

debugProvideOutputStream

public MessageOutputStream debugProvideOutputStream(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                    PipeLineSession session)
                                             throws Throwable

Provides advice for IOutputStreamingSupport.provideOutputStream(PipeLineSession session, IForwardTarget next)

Throws:

Throwable

inspectXml

public ContentHandler inspectXml(PipeLineSession session,
                                 String label,
                                 ContentHandler contentHandler,
                                 BiConsumer<AutoCloseable,String> closeOnCloseRegister)

Description copied from interface: IXmlDebugger

Allow the debugger to see the XML stream.

Specified by:

inspectXml in interface IXmlDebugger

debugSenderGetInputFrom

public SenderResult debugSenderGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                            SenderWrapperBase senderWrapperBase,
                                            Message message,
                                            PipeLineSession session)
                                     throws Throwable

Provides advice for CacheSenderWrapperProcessor.sendMessage(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)

Throws:

Throwable

debugReplyListenerInputOutputAbort

public <M> M debugReplyListenerInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                                ICorrelatedPullingListener<M> listener,
                                                String correlationId,
                                                PipeLineSession pipeLineSession)
                                         throws Throwable

Throws:

Throwable

debugThreadCreateStartEndAbort

public Object debugThreadCreateStartEndAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                             Runnable runnable)
                                      throws Throwable

Throws:

Throwable

announceChildThread

public nl.nn.ibistesttool.ThreadDebugInfo announceChildThread(Object owner,
                                                              String correlationId)

Specified by:

announceChildThread in interface ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>

cancelChildThread

public void cancelChildThread(nl.nn.ibistesttool.ThreadDebugInfo threadInfo)

Specified by:

cancelChildThread in interface ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>

threadCreated

public <R> R threadCreated(nl.nn.ibistesttool.ThreadDebugInfo ref,
                           R request)

Specified by:

threadCreated in interface ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>

threadEnded

public <R> R threadEnded(nl.nn.ibistesttool.ThreadDebugInfo ref,
                         R result)

Specified by:

threadEnded in interface ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>

threadAborted

public Throwable threadAborted(nl.nn.ibistesttool.ThreadDebugInfo ref,
                               Throwable t)

Specified by:

threadAborted in interface ThreadLifeCycleEventListener<nl.nn.ibistesttool.ThreadDebugInfo>

debugParameterResolvedTo

public Object debugParameterResolvedTo(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
                                       ParameterValueList alreadyResolvedParameters,
                                       Message message,
                                       PipeLineSession session,
                                       boolean namespaceAware)
                                throws Throwable

Provides advice for Parameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)

Throws:

Throwable

getCorrelationId

public String getCorrelationId(PipeLineSession session)

setEnabled

public void setEnabled(boolean enable)

isEnabled

public boolean isEnabled()

onApplicationEvent

public void onApplicationEvent(DebuggerStatusChangedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<DebuggerStatusChangedEvent>