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
static String	RESULT_STATE_HEADER
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
org.springframework.messaging.Message<Object>	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

RESULT_STATE_HEADER

public static final String RESULT_STATE_HEADER

See Also:

Constant Field Values

Constructor Detail

TestPipeline

public TestPipeline()

Method Detail

runTestPipeline

@ActionSelector(value=UPLOAD)
public org.springframework.messaging.Message<Object> 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