public class FxfWrapperPipe extends EsbSoapWrapperPipe
EsbSoapWrapperPipe.Mode
IWrapperPipe.Direction
APPLICATIONFUNCTION, APPLICATIONNAME, BUSINESSDOMAIN, CMHVERSION, CONVERSATIONID, CORRELATIONID, CPAID, DESTINATION, EXTERNALREFTOMESSAGEID, FIXRESULTNAMESPACE, FROMID, MESSAGEID, MESSAGINGLAYER, MODE, OPERATIONNAME, OPERATIONVERSION, OUTPUTNAMESPACEBASEURI, PARADIGM, PHYSICALDESTINATION, SERVICECONTEXT, SERVICECONTEXTVERSION, SERVICELAYER, SERVICENAME, TIMESTAMP, TRANSACTIONID
DEFAULT_SOAP_HEADER_SESSION_KEY, DEFAULT_SOAP_NAMESPACE_SESSION_KEY, DEFAULT_SOAP_VERSION_FOR_WRAPPING
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
FxfWrapperPipe() |
Modifier and Type | Method and Description |
---|---|
void |
configure()
checks for correct configuration of forward
|
PipeRunResult |
doPipe(Message message,
PipeLineSession session)
This is where the action takes place.
|
void |
setClientFilenameSessionKey(String clientFilenameSessionKey) |
void |
setCreateFolder(boolean createFolder)
when set to
true , the folder corresponding fxf.dir property will be created in case it does not exist |
void |
setFlowId(String flowId)
The flowId of the file transfer when direction=wrap.
|
void |
setFlowIdSessionKey(String flowIdSessionKey) |
void |
setFlowOutFolder(String flowOutFolder)
specifies the output folder if transformFilename=
false and direction=wrap |
void |
setFxfDirSessionKey(String fxfDirSessionKey) |
void |
setFxfFileSessionKey(String fxfFileSessionKey) |
void |
setFxfVersion(String fxfVersion)
either 3.1 or 3.2
|
void |
setSoapBodySessionKey(String soapBodySessionKey) |
void |
setTransferFlowIdSessionKey(String transferFlowIdSessionKey) |
void |
setTransformFilename(boolean transformFilename)
when
true and direction=wrap, the input which is expected to be a local filename will be transformed to the filename as known on the IUF State machine. |
void |
setUseServerFilename(boolean useServerFilename)
when set to
true , ServerFileName from the input will be used as the filename |
void |
start()
Perform necessary action to start the pipe.
|
void |
stop()
Perform necessary actions to stop the
Pipe .For instance, closing JMS connections, DBMS connections etc. |
getApplicationFunction, getApplicationName, getBusinessDomain, getDestination, getMessagingLayer, getOperationName, getOperationVersion, getOutputNamespaceBaseUri, getParadigm, getServiceContext, getServiceContextVersion, getServiceLayer, getServiceName, isEsbDestinationWithoutServiceContext, isEsbNamespaceWithoutServiceContext, isValidNamespace, retrievePhysicalDestinationFromListener, retrievePhysicalDestinationFromSender, setAddOutputNamespace, setCmhVersion, setEsbAlias, setFixResultNamespace, setMode, setP2pAlias, setRetrievePhysicalDestination, setUseFixedValues
setAllowPlainXml, setDirection, setEncodingStyle, setIgnoreSoapFault, setOutputNamespace, setRemoveOutputNamespaces, setRemoveUnusedOutputNamespaces, setRoot, setServiceNamespace, setSoapBodyStyleSheet, setSoapHeaderSessionKey, setSoapHeaderStyleSheet, setSoapNamespace, setSoapNamespaceSessionKey, setSoapVersion, setWssAuthAlias, setWssPassword, setWssPasswordDigest, setWssUserName, unwrapMessage, wrapMessage
getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
addParameter, consumesSessionVariable, createBean, findForward, getAdapter, getEventSourceName, getForwards, getInSizeStatDummyObject, getOutSizeStatDummyObject, getParameterList, hasSizeStatistics, registerEvent, registerForward, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setHideRegex, setLocker, setLogIntermediaryResults, setMaxThreads, setName, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, throwEvent
configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setName
consumesSessionVariable, getForwards, getMaxThreads, registerForward
getName
getApplicationContext, getName
getConfigurationClassLoader
setApplicationContext
getName
getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getLocker, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
public void configure() throws ConfigurationException
FixedForwardPipe
configure
in interface IConfigurable
configure
in interface IPipe
configure
in class EsbSoapWrapperPipe
ConfigurationException
public void start() throws PipeStartException
IPipe
IPipe.configure()
method, for each start and stop command of the
adapter.start
in interface IPipe
start
in class SoapWrapperPipe
PipeStartException
public void stop()
IPipe
Pipe
.stop
in interface IPipe
stop
in class SoapWrapperPipe
public PipeRunResult doPipe(Message message, PipeLineSession session) throws PipeRunException
IPipe
FixedResultPipe
, the Pipe
can schedule the input to be closed at session exit, by calling Message.closeOnCloseOf(PipeLineSession, String)
This allows the previous Pipe to release any resources (e.g. connections) that it might have kept open
until the message was consumed. Doing so avoids connections leaking from pools, while it enables
efficient streaming processing of data while it is being read from a stream.doPipe
in interface IPipe
doPipe
in class SoapWrapperPipe
PipeRunException
public void setFlowId(String flowId)
public void setFlowOutFolder(String flowOutFolder)
false
and direction=wrappublic void setTransformFilename(boolean transformFilename)
true
and direction=wrap, the input which is expected to be a local filename will be transformed to the filename as known on the IUF State machine.public void setSoapBodySessionKey(String soapBodySessionKey)
public void setTransferFlowIdSessionKey(String transferFlowIdSessionKey)
public void setClientFilenameSessionKey(String clientFilenameSessionKey)
public void setFlowIdSessionKey(String flowIdSessionKey)
public void setFxfDirSessionKey(String fxfDirSessionKey)
public void setFxfFileSessionKey(String fxfFileSessionKey)
public void setFxfVersion(String fxfVersion)
public void setCreateFolder(boolean createFolder)
true
, the folder corresponding fxf.dir property will be created in case it does not existpublic void setUseServerFilename(boolean useServerFilename)
true
, ServerFileName from the input will be used as the filenameCopyright © 2023 Frank!Framework. All rights reserved.