nl.nn.adapterframework.management.bus.endpoints

Class TestPipeline

java.lang.Object

nl.nn.adapterframework.management.bus.endpoints.BusEndpointBase

nl.nn.adapterframework.management.bus.endpoints.TestPipeline

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware

@BusAware(value="frank-management-bus")
 @TopicSelector(value=TEST_PIPELINE)
public class TestPipeline
extends BusEndpointBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestPipeline.PostedSessionKey

Field Summary

Fields

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

Fields inherited from class nl.nn.adapterframework.management.bus.endpoints.BusEndpointBase

log

Constructor Summary

Constructors

Constructor and Description
TestPipeline()

Method Summary

Modifier and Type	Method and Description
protected Map<String,String>	getSessionKeysFromHeader(String sessionKeys) Parses SessionKeys from the sessionKeys header.
protected Map<String,String>	getSessionKeysFromPayload(String input) Parses the 'ibiscontext' processing instruction defined in the input
BinaryResponseMessage	runTestPipeline(org.springframework.messaging.Message<?> message)

Methods inherited from class nl.nn.adapterframework.management.bus.endpoints.BusEndpointBase

afterPropertiesSet, createBean, doAfterPropertiesSet, getAdapterByName, getApplicationContext, getBean, getConfigurationByName, getIbisManager, getMediaTypeFromName, getPipeByName, getReceiverByName, log2SecurityLog, setApplicationContext

Methods inherited from class java.lang.Object

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

Field Detail

secLog

protected org.apache.logging.log4j.Logger secLog

Constructor Detail

TestPipeline

public TestPipeline()

Method Detail

runTestPipeline

@ActionSelector(value=UPLOAD)
public BinaryResponseMessage runTestPipeline(org.springframework.messaging.Message<?> message)

getSessionKeysFromHeader

@Nonnull
protected Map<String,String> getSessionKeysFromHeader(String sessionKeys)

Parses SessionKeys from the sessionKeys header. Format: [{"index":1,"key":"test","value":"123"}]

getSessionKeysFromPayload

@Nonnull
protected Map<String,String> getSessionKeysFromPayload(String input)

Parses the 'ibiscontext' processing instruction defined in the input