Class GetTibcoQueues
java.lang.Object
org.frankframework.core.TransactionAttributes
org.frankframework.pipes.AbstractPipe
org.frankframework.pipes.FixedForwardPipe
org.frankframework.pipes.TimeoutGuardPipe
org.frankframework.extensions.tibco.GetTibcoQueues
- All Implemented Interfaces:
FrankElement
,HasApplicationContext
,HasName
,HasTransactionAttribute
,IConfigurable
,IForwardTarget
,IPipe
,IScopeProvider
,IWithParameters
,NameAware
,EventThrowing
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
,org.springframework.context.Lifecycle
Returns information about Tibco queues in a XML string.
If the parameter queueName
is empty then
- all Tibco queues including information about these queues are returned
- one message on a specific Tibco queue including information about this message is returned (without removing it)
- Author:
- Peter Leeuwenburgh
- Specific parameters
- url When a parameter with name url is present, it is used instead of the url specified by the attribute, authAlias When a parameter with name authAlias is present, it is used instead of the authAlias specified by the attribute, username When a parameter with name userName is present, it is used instead of the userName specified by the attribute, password When a parameter with name password is present, it is used instead of the password specified by the attribute, queueName The name of the queue which is used for browsing one queue, queueItem The number of the queue message which is used for browsing one queue (default is 1), showAge When set to
true
andpendingMsgCount>0
andreceiverCount=0
, the age of the current first message in the queue is shown in the queues overview (default is false), countOnly When set totrue
andqueueName
is filled, only the number of pending messages is returned (default is false), ldapUrl When present, principal descriptions are retrieved from this LDAP server
-
Field Summary
Fields inherited from class org.frankframework.pipes.AbstractPipe
parameterNamesMustBeUnique
Fields inherited from class org.frankframework.core.TransactionAttributes
log
Fields inherited from interface org.frankframework.core.IPipe
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Checks for correct configuration of forward.doPipeWithTimeoutGuarded
(Message input, PipeLineSession session) doPipe wrapped around a TimeoutGuardgetUrl()
boolean
boolean
void
setAuthAlias
(String string) alias used to obtain credentials for authentication to hostvoid
setEmsPropertiesFile
(String propertyFile) Location to ajndi.properties
file for additional EMS (SSL) propertiesvoid
setHideMessage
(boolean b) when set totrue
, the length of the queue message is returned instead of the queue message self (when parameterqueueName
is not empty)void
setPassword
(String string) password used in authentication to hostvoid
setQueueRegex
(String string) void
setSkipTemporaryQueues
(boolean b) when set totrue
, temporary queues are skippedvoid
URL or base of URL to be used.void
setUsername
(String string) username used in authentication to hostMethods inherited from class org.frankframework.pipes.TimeoutGuardPipe
doPipe, getTimeout, isThrowException, killPipe, setThrowException, setTimeout
Methods inherited from class org.frankframework.pipes.FixedForwardPipe
getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
Methods inherited from class org.frankframework.pipes.AbstractPipe
addForward, addParameter, consumesSessionVariable, createBean, findForward, getAdapter, getEventSourceName, getForwards, getParameterList, hasRegisteredForward, isRunning, registerEvent, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setHideRegex, setLocker, setLogIntermediaryResults, setMaxThreads, setName, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, sizeStatisticsEnabled, start, stop, throwEvent
Methods inherited from class org.frankframework.core.TransactionAttributes
configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.frankframework.core.HasApplicationContext
getApplicationContext, getConfigurationClassLoader
Methods inherited from interface org.frankframework.core.HasTransactionAttribute
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
Methods inherited from interface org.frankframework.core.IForwardTarget
getName
Methods inherited from interface org.frankframework.core.IPipe
getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getHideRegex, getLocker, getLogIntermediaryResults, getMaxThreads, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent
-
Constructor Details
-
GetTibcoQueues
public GetTibcoQueues()
-
-
Method Details
-
configure
Description copied from class:FixedForwardPipe
Checks for correct configuration of forward.- Specified by:
configure
in interfaceIConfigurable
- Overrides:
configure
in classFixedForwardPipe
- Throws:
ConfigurationException
- in case it was not able to configure the component.
-
doPipeWithTimeoutGuarded
public PipeRunResult doPipeWithTimeoutGuarded(Message input, PipeLineSession session) throws PipeRunException Description copied from class:TimeoutGuardPipe
doPipe wrapped around a TimeoutGuard- Specified by:
doPipeWithTimeoutGuarded
in classTimeoutGuardPipe
- Throws:
PipeRunException
-
getUrl
-
setUrl
URL or base of URL to be used. When multiple URLs are defined (comma separated list), the first URL is used of which the server has an active state -
getAuthAlias
-
setAuthAlias
alias used to obtain credentials for authentication to host -
getUsername
-
setUsername
username used in authentication to host -
getPassword
-
setPassword
password used in authentication to host -
isSkipTemporaryQueues
public boolean isSkipTemporaryQueues() -
setSkipTemporaryQueues
public void setSkipTemporaryQueues(boolean b) when set totrue
, temporary queues are skipped- Default value
- false
-
isHideMessage
public boolean isHideMessage() -
setHideMessage
public void setHideMessage(boolean b) when set totrue
, the length of the queue message is returned instead of the queue message self (when parameterqueueName
is not empty)- Default value
- false
-
getQueueRegex
-
setQueueRegex
-
setEmsPropertiesFile
Location to ajndi.properties
file for additional EMS (SSL) properties
-