Package org.frankframework.management.bus.endpoints

Class TestPipeline

java.lang.Object

org.frankframework.management.bus.endpoints.BusEndpointBase

org.frankframework.management.bus.endpoints.TestPipeline

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestPipeline.PostedSessionKey

Field Summary

Fields

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

Fields inherited from class org.frankframework.management.bus.endpoints.BusEndpointBase

log

Constructor Summary

Constructors

Constructor	Description
TestPipeline()

Method Summary

Modifier and Type	Method	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
BinaryMessage	runTestPipeline(org.springframework.messaging.Message<?> message)

Methods inherited from class org.frankframework.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 Details

secLog

protected org.apache.logging.log4j.Logger secLog

Constructor Details

TestPipeline

public TestPipeline()

Method Details

runTestPipeline

@ActionSelector(UPLOAD)
@RolesAllowed("IbisTester")
public BinaryMessage 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