Package org.frankframework.ladybug

Class IbisDebuggerAdvice

java.lang.Object

org.frankframework.ladybug.IbisDebuggerAdvice

All Implemented Interfaces:

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

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

Author:

Jaco de Groot, Niels Meijer

Field Summary

Fields

Modifier and Type	Field	Description
protected IbisManager	ibisManager

Constructor Summary

Constructors

Constructor	Description
IbisDebuggerAdvice()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
ThreadDebugInfo	announceChildThread(Object owner, String correlationId)
void	cancelChildThread(ThreadDebugInfo threadInfo)
SenderResult	debugBlockEnabledSenderInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Object blockHandle, Message message, PipeLineSession pipeLineSession)	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 AbstractParameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)
PipeRunResult	debugPipeGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)	Provides advice for LimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) LimitingParallelExecutionPipeProcessor 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 pipeLineSession)	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 pipeLineSession)	Provides advice for CorePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession session, String firstPipe)
<M> M	debugReplyListenerInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, ICorrelatedPullingListener<M> listener, String correlationId, PipeLineSession pipeLineSession)
SenderResult	debugSenderGetInputFrom(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, AbstractSenderWrapper senderWrapperBase, Message message, PipeLineSession pipeLineSession)	Provides advice for CacheSenderWrapperProcessor.sendMessage(AbstractSenderWrapper senderWrapperBase, Message message, PipeLineSession session)
SenderResult	debugSenderSendMessage(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession pipeLineSession)	Provides advice for ISender.sendMessage(Message message, PipeLineSession session)
Message	debugSenderSendMessageOrThrow(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession pipeLineSession)	Provides advice for ISender.sendMessageOrThrow(Message message, PipeLineSession session)
Object	debugThreadCreateStartEndAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Runnable runnable)
PipeRunResult	debugValidatorInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)
String	getCorrelationId(PipeLineSession session)
ContentHandler	inspectXml(PipeLineSession session, String label, ContentHandler contentHandler)	Allow the debugger to see the XML stream.
static Writer	limitSize(Writer writer, int maxSize)
void	onApplicationEvent(DebuggerStatusChangedEvent event)
Throwable	threadAborted(ThreadDebugInfo ref, Throwable t)
<R> R	threadCreated(ThreadDebugInfo ref, R request)
<R> R	threadEnded(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

supportsAsyncExecution

Field Details

ibisManager

@Autowired
protected IbisManager ibisManager

Constructor Details

IbisDebuggerAdvice

public IbisDebuggerAdvice()

Method Details

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

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

debugPipeLineInputOutputAbort

public PipeLineResult debugPipeLineInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
 PipeLine pipeLine,
 String messageId,
 Message message,
 PipeLineSession pipeLineSession)
                                             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 pipeLineSession)
                                        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 pipeLineSession)
                                    throws Throwable

Provides advice for LimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) LimitingParallelExecutionPipeProcessor 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 pipeLineSession,
 String messageRoot)
                                             throws Throwable

Throws:

Throwable

debugSenderSendMessageOrThrow

public Message debugSenderSendMessageOrThrow(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint,
 Message message,
 PipeLineSession pipeLineSession)
                                      throws Throwable

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

Throws:

Throwable

debugSenderSendMessage

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

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

Throws:

Throwable

debugBlockEnabledSenderInputOutputAbort

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

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

Throws:

Throwable

inspectXml

public ContentHandler inspectXml(PipeLineSession session,
 String label,
 ContentHandler contentHandler)

Description copied from interface: IXmlDebugger

Allow the debugger to see the XML stream.

Specified by:

inspectXml in interface IXmlDebugger

limitSize

public static Writer limitSize(Writer writer,
 int maxSize)

debugSenderGetInputFrom

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

Provides advice for CacheSenderWrapperProcessor.sendMessage(AbstractSenderWrapper 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 ThreadDebugInfo announceChildThread(Object owner,
 String correlationId)

Specified by:

announceChildThread in interface ThreadLifeCycleEventListener<ThreadDebugInfo>

cancelChildThread

public void cancelChildThread(ThreadDebugInfo threadInfo)

Specified by:

cancelChildThread in interface ThreadLifeCycleEventListener<ThreadDebugInfo>

threadCreated

public <R> R threadCreated(ThreadDebugInfo ref,
 R request)

Specified by:

threadCreated in interface ThreadLifeCycleEventListener<ThreadDebugInfo>

threadEnded

public <R> R threadEnded(ThreadDebugInfo ref,
 R result)

Specified by:

threadEnded in interface ThreadLifeCycleEventListener<ThreadDebugInfo>

threadAborted

public Throwable threadAborted(ThreadDebugInfo ref,
 Throwable t)

Specified by:

threadAborted in interface ThreadLifeCycleEventListener<ThreadDebugInfo>

debugParameterResolvedTo

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

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

Throws:

Throwable

getCorrelationId

public String getCorrelationId(PipeLineSession session)

onApplicationEvent

public void onApplicationEvent(@Nonnull
 DebuggerStatusChangedEvent event)

Specified by:

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