Package org.frankframework.jdbc

Class JdbcListener<M>

java.lang.Object

org.frankframework.jndi.JndiBase

org.frankframework.jdbc.JdbcFacade

org.frankframework.jdbc.JdbcListener<M>

Type Parameters:

M - MessageWrapper or key. Key is also used as messageId

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, IHasProcessState<M>, IListener<M>, INamedObject, IPeekableListener<M>, IPullingListener<M>, IScopeProvider, IXAEnabled, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

JdbcQueryListener, JdbcTableListener

public class JdbcListener<M>
extends JdbcFacade
implements IPeekableListener<M>, IHasProcessState<M>

JdbcListener base class.

Since:

4.7

Author:

Gerrit van Brakel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	JdbcListener.MessageFieldType

Field Summary

Fields

Modifier and Type	Field	Description
protected Connection	connection

Fields inherited from class org.frankframework.jndi.JndiBase

log

Constructor Summary

Constructors

Constructor	Description
JdbcListener()

Method Summary

Modifier and Type	Method	Description
void	afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)	Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.
protected RawMessageWrapper<M>	changeProcessState(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
RawMessageWrapper<M>	changeProcessState(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)	Change the processState of the message to the specified state, if that state is supported.
void	close()	Close all resources used for listening.
void	closeThread(Map<String,Object> threadContext)	Finalizes a message receiving thread.
void	configure()	configure() is called once at startup of the framework in the configure() method of the owner of this listener.
protected String	convertQuery(String query)
protected boolean	execute(Connection conn, String query, String... parameters)
Message	extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)	Extracts data from message obtained from IPullingListener.getRawMessage(Map) or IPushingListener.wrapRawMessage(Object, PipeLineSession).
protected MessageWrapper<M>	extractRawMessage(ResultSet rs)	This method returns a MessageWrapper containing contents of the message stored in the database.
String	getBlobCharset()
String	getCorrelationIdField()
String	getKeyField()
protected String	getKeyFromRawMessage(RawMessageWrapper<M> rawMessage)
String	getMessageField()
JdbcListener.MessageFieldType	getMessageFieldType()
String	getMessageIdField()
String	getPeekQuery()
protected RawMessageWrapper<M>	getRawMessage(Connection conn, Map<String,Object> threadContext)
RawMessageWrapper<M>	getRawMessage(Map<String,Object> threadContext)	Retrieves messages from queue or other channel, but does no processing on it.
String	getSelectQuery()
String	getSqlDialect()
String	getUpdateStatusQuery(ProcessState state)
boolean	hasRawMessageAvailable()
protected boolean	hasRawMessageAvailable(Connection conn)
boolean	isBlobsCompressed()
boolean	isBlobSmartGet()
boolean	isPeekUntransacted()
boolean	isTrace()
Set<ProcessState>	knownProcessStates()	Provides the set of ProcessStates used by this listener.
void	open()	Prepares the listener for receiving messages.
Map<String,Object>	openThread()	Prepares a thread for receiving messages.
void	setBlobCharset(String string)	Deprecated.
void	setBlobsCompressed(boolean b)	Controls whether BLOB is considered stored compressed in the database
void	setBlobSmartGet(boolean b)	Controls automatically whether blobdata is stored compressed and/or serialized in the database.
void	setCorrelationIdField(String fieldname)	Field containing the correlationId.
void	setKeyField(String fieldname)	Primary key field of the table, used to identify and differentiate messages.
void	setMessageField(String fieldname)	Field containing the message data
void	setMessageFieldType(JdbcListener.MessageFieldType value)	Type of the field containing the message data
void	setMessageIdField(String fieldname)	Field containing the messageId.
void	setPeekQuery(String string)	(only used when peekUntransacted=true) peek query to determine if the select query should be executed.
void	setPeekUntransacted(boolean b)	when true, then PollingListener container will execute getRawMessage() only when hasRawMessageAvailable() has returned true.
protected void	setSelectQuery(String string)
void	setSqlDialect(String string)	If set, the SQL dialect in which the queries are written and should be translated from to the actual SQL dialect
void	setTrace(boolean trace)
protected void	setUpdateStatusQuery(ProcessState state, String query)
Map<ProcessState,Set<ProcessState>>	targetProcessStates()	Provides the set of ProcessStates that a message in the specified state can be moved to, e.g.

Methods inherited from class org.frankframework.jdbc.JdbcFacade

getAuthAlias, getConnection, getConnectionWithTimeout, getDatasource, getDataSourceFactory, getDatasourceInfo, getDatasourceName, getDbmsSupport, getDomain, getLogPrefix, getPassword, getPhysicalDestinationName, getUsername, isConnectionsArePooled, isTransacted, setAuthAlias, setConnectionsArePooled, setDataSourceFactory, setDatasourceName, setDbmsSupportFactory, setJmsRealm, setPassword, setTransacted, setUsername

Methods inherited from class org.frankframework.jndi.JndiBase

getApplicationContext, getAuthentication, getConfigurationClassLoader, getContext, getCredentials, getInitialContextFactoryName, getJmsRealmName, getJndiAuthAlias, getJndiContextPrefix, getJndiEnv, getJndiProperties, getName, getPrincipal, getProviderURL, getSecurityProtocol, getUrlPkgPrefixes, setApplicationContext, setAuthentication, setCredentials, setInitialContextFactoryName, setJndiAuthAlias, setJndiContextPrefix, setJndiProperties, setName, setPrincipal, setProviderURL, setSecurityProtocol, setUrlPkgPrefixes, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface org.frankframework.core.INamedObject

getName, setName

Methods inherited from interface org.frankframework.core.IScopeProvider

getConfigurationClassLoader

Field Details

connection

protected Connection connection

Constructor Details

JdbcListener

public JdbcListener()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IListener

configure() is called once at startup of the framework in the configure() method of the owner of this listener. Purpose of this method is to reduce creating connections to databases etc. in the IPullingListener.getRawMessage(Map) method. As much as possible class-instantiating should take place in the configure() or open() method, to improve performance.

Specified by:

configure in interface IConfigurable

Specified by:

configure in interface IListener<M>

Overrides:

configure in class JdbcFacade

Throws:

ConfigurationException

open

public void open()
          throws ListenerException

Description copied from interface: IListener

Prepares the listener for receiving messages. open() is called once each time the listener is started.

Specified by:

open in interface IListener<M>

Throws:

ListenerException

close

public void close()

Description copied from interface: IListener

Close all resources used for listening. Called once each time the listener is stopped.

Specified by:

close in interface IListener<M>

Overrides:

close in class JndiBase

openThread

@Nonnull
public Map<String,Object> openThread()
                              throws ListenerException

Description copied from interface: IPullingListener

Prepares a thread for receiving messages. Called once for each thread that will listen for messages.

Specified by:

openThread in interface IPullingListener<M>

Returns:

the threadContext for this thread. The threadContext is a Map in which thread-specific data can be stored. May not be null, must be a mutable map type.

Throws:

ListenerException

closeThread

public void closeThread(@Nonnull
 Map<String,Object> threadContext)
                 throws ListenerException

Description copied from interface: IPullingListener

Finalizes a message receiving thread. Called once for each thread that listens for messages, just before IListener.close() is called.

Specified by:

closeThread in interface IPullingListener<M>

Throws:

ListenerException

hasRawMessageAvailable

public boolean hasRawMessageAvailable()
                               throws ListenerException

Specified by:

hasRawMessageAvailable in interface IPeekableListener<M>

Throws:

ListenerException

hasRawMessageAvailable

protected boolean hasRawMessageAvailable(Connection conn)
                                  throws ListenerException

Throws:

ListenerException

getRawMessage

public RawMessageWrapper<M> getRawMessage(@Nonnull
 Map<String,Object> threadContext)
                                   throws ListenerException

Description copied from interface: IPullingListener

Retrieves messages from queue or other channel, but does no processing on it. Multiple objects may try to call this method at the same time, from different threads. Implementations of this method should therefore be thread-safe, or synchronized.

Any thread-specific properties should be stored in and retrieved from the threadContext.

Specified by:

getRawMessage in interface IPullingListener<M>

Throws:

ListenerException

getRawMessage

protected RawMessageWrapper<M> getRawMessage(Connection conn,
 Map<String,Object> threadContext)
                                      throws ListenerException

Throws:

ListenerException

extractRawMessage

protected MessageWrapper<M> extractRawMessage(ResultSet rs)
                                       throws JdbcException

This method returns a MessageWrapper containing contents of the message stored in the database.

Parameters:

rs - JDBC ResultSet from which to extract message data.

Returns:

Either a String being the message key, or a MessageWrapper. The message key as String is returned if messageField, messageIdField and correlationIdField all are not set. If messageIdField and / or correlationIdField are set but messageField is not, then the message key is returned as value of a Message wrapped in a MessageWrapper. Otherwise the message is loaded from the rs parameter and returned wrapped in a MessageWrapper.

Throws:

JdbcException - If loading the message resulted in a database exception.

getKeyFromRawMessage

protected String getKeyFromRawMessage(RawMessageWrapper<M> rawMessage)
                               throws ListenerException

Throws:

ListenerException

extractMessage

public Message extractMessage(@Nonnull
 RawMessageWrapper<M> rawMessage,
 @Nonnull
 Map<String,Object> context)
                       throws ListenerException

Description copied from interface: IListener

Extracts data from message obtained from IPullingListener.getRawMessage(Map) or IPushingListener.wrapRawMessage(Object, PipeLineSession). May also extract other parameters from the message and put those into the context.

Specified by:

extractMessage in interface IListener<M>

Parameters:

rawMessage - The RawMessageWrapper from which to extract the Message.

context - Context to populate. Either a PipeLineSession or a Map threadContext depending on caller.

Returns:

input Message for adapter.

Throws:

ListenerException

afterMessageProcessed

public void afterMessageProcessed(PipeLineResult processResult,
 RawMessageWrapper<M> rawMessage,
 PipeLineSession pipeLineSession)
                           throws ListenerException

Description copied from interface: IListener

Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.

Specified by:

afterMessageProcessed in interface IListener<M>

Throws:

ListenerException

knownProcessStates

public Set<ProcessState> knownProcessStates()

Description copied from interface: IHasProcessState

Provides the set of ProcessStates used by this listener.

Specified by:

knownProcessStates in interface IHasProcessState<M>

targetProcessStates

public Map<ProcessState,Set<ProcessState>> targetProcessStates()

Description copied from interface: IHasProcessState

Provides the set of ProcessStates that a message in the specified state can be moved to, e.g. from a MessageBrowser for that state.

Specified by:

targetProcessStates in interface IHasProcessState<M>

changeProcessState

public RawMessageWrapper<M> changeProcessState(RawMessageWrapper<M> rawMessage,
 ProcessState toState,
 String reason)
                                        throws ListenerException

Description copied from interface: IHasProcessState

Change the processState of the message to the specified state, if that state is supported. If it is not supported, nothing changes, and false is returned.

Specified by:

changeProcessState in interface IHasProcessState<M>

Returns:

the moved message, or null if no message was moved.

Throws:

ListenerException

changeProcessState

protected RawMessageWrapper<M> changeProcessState(Connection connection,
 RawMessageWrapper<M> rawMessage,
 ProcessState toState,
 String reason)
                                           throws ListenerException

Throws:

ListenerException

execute

protected boolean execute(Connection conn,
 String query,
 String... parameters)
                   throws ListenerException

Throws:

ListenerException

convertQuery

protected String convertQuery(String query)
                       throws SQLException,
DbmsException

Throws:

SQLException

DbmsException

setUpdateStatusQuery

protected void setUpdateStatusQuery(ProcessState state,
 String query)

getUpdateStatusQuery

public String getUpdateStatusQuery(ProcessState state)

setSelectQuery

protected void setSelectQuery(String string)

setPeekUntransacted

public void setPeekUntransacted(boolean b)

Description copied from interface: IPeekableListener

when true, then PollingListener container will execute getRawMessage() only when hasRawMessageAvailable() has returned true. This avoids rolling back a lot of XA transactions, that appears to be problematic on MS SQL Server

Specified by:

setPeekUntransacted in interface IPeekableListener<M>

setPeekQuery

public void setPeekQuery(String string)

(only used when peekUntransacted=true) peek query to determine if the select query should be executed. Peek queries are, unlike select queries, executed without a transaction and without a rowlock

Default value

selectQuery

setKeyField

public void setKeyField(String fieldname)

Primary key field of the table, used to identify and differentiate messages. NB: there should be an index on this field!

setMessageField

public void setMessageField(String fieldname)

Field containing the message data

Default value

same as keyField

setMessageFieldType

public void setMessageFieldType(JdbcListener.MessageFieldType value)

Type of the field containing the message data

Default value

String

setMessageIdField

public void setMessageIdField(String fieldname)

Field containing the messageId. NB: If this column is not set the default (primary key) keyField will be used as messageId!

Default value

same as keyField

setCorrelationIdField

public void setCorrelationIdField(String fieldname)

Field containing the correlationId. NB: If this column is not set, the messageId and correlationId will be the same!

Default value

same as messageIdField

setSqlDialect

public void setSqlDialect(String string)

If set, the SQL dialect in which the queries are written and should be translated from to the actual SQL dialect

setBlobsCompressed

public void setBlobsCompressed(boolean b)

Controls whether BLOB is considered stored compressed in the database

Default value

true

setBlobCharset

@Deprecated
public void setBlobCharset(String string)

Deprecated.

Charset used to read BLOB. When specified, then the BLOB will be converted into a string

setBlobSmartGet

public void setBlobSmartGet(boolean b)

Controls automatically whether blobdata is stored compressed and/or serialized in the database. N.B. When set true, then the BLOB will be converted into a string

Default value

false

getSelectQuery

public String getSelectQuery()

getPeekQuery

public String getPeekQuery()

getKeyField

public String getKeyField()

getMessageField

public String getMessageField()

getMessageIdField

public String getMessageIdField()

getCorrelationIdField

public String getCorrelationIdField()

getMessageFieldType

public JdbcListener.MessageFieldType getMessageFieldType()

getSqlDialect

public String getSqlDialect()

getBlobCharset

public String getBlobCharset()

isBlobsCompressed

public boolean isBlobsCompressed()

isBlobSmartGet

public boolean isBlobSmartGet()

setTrace

public void setTrace(boolean trace)

isTrace

public boolean isTrace()

isPeekUntransacted

public boolean isPeekUntransacted()

Specified by:

isPeekUntransacted in interface IPeekableListener<M>