nl.nn.adapterframework.jdbc

Class JdbcListener<M>

java.lang.Object

nl.nn.adapterframework.jndi.JndiBase

nl.nn.adapterframework.jdbc.JdbcFacade

nl.nn.adapterframework.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, HasStatistics, 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 and Description
static class	JdbcListener.MessageFieldType

Nested classes/interfaces inherited from interface nl.nn.adapterframework.statistics.HasStatistics

HasStatistics.Action

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	connection

Fields inherited from class nl.nn.adapterframework.jndi.JndiBase

log

Constructor Summary

Constructors

Constructor and Description
JdbcListener()

Method Summary

Modifier and Type	Method and 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.
protected String	getKeyFromRawMessage(RawMessageWrapper<M> rawMessage)
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	getUpdateStatusQuery(ProcessState state)
boolean	hasRawMessageAvailable()
protected boolean	hasRawMessageAvailable(Connection conn)
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 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 message Id
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 nl.nn.adapterframework.jdbc.JdbcFacade

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

Methods inherited from class nl.nn.adapterframework.jndi.JndiBase

getContext, getJndiEnv, 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 nl.nn.adapterframework.core.IPeekableListener

isPeekUntransacted

Methods inherited from interface nl.nn.adapterframework.core.INamedObject

getName, setName

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain

Field Detail

connection

protected Connection connection

Constructor Detail

JdbcListener

public JdbcListener()

Method Detail

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 JdbcException,
                              SQLException

Throws:

JdbcException

SQLException

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 messages. For optimal performance, 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 message Id

Default value

same as keyField

setCorrelationIdField

public void setCorrelationIdField(String fieldname)

Field containing the correlationId

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

setTrace

public void setTrace(boolean trace)