Package org.axonframework.eventhandling.deadletter.jdbc

Class DefaultDeadLetterJdbcConverter<E extends EventMessage<?>>

java.lang.Object

org.axonframework.eventhandling.deadletter.jdbc.DefaultDeadLetterJdbcConverter<E>

Type Parameters:

E - An implementation of EventMessage contained within the JdbcDeadLetter implementation this converter converts.

All Implemented Interfaces:

DeadLetterJdbcConverter<E,JdbcDeadLetter<E>>

public class DefaultDeadLetterJdbcConverter<E extends EventMessage<?>>
extends Object
implements DeadLetterJdbcConverter<E,JdbcDeadLetter<E>>

Default implementation of the DeadLetterJdbcConverter, converting ResultSets into JdbcDeadLetter instances.

This converter expects a DeadLetterSchema to define the column names / labels used to retrieve the fields from the ResultSet. Furthermore, it uses the configurable genericSerializer to deserialize TrackingTokens for TrackedEventMessage instances. Lastly, this factory uses the eventSerializer to deserialize the event payload, MetaData, and diagnostics for the JdbcDeadLetter to return.

Since:

4.8.0

Author:

Steven van Beelen

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultDeadLetterJdbcConverter.Builder<E extends EventMessage<?>>	Builder class to instantiate a DefaultDeadLetterJdbcConverter.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultDeadLetterJdbcConverter(DefaultDeadLetterJdbcConverter.Builder<E> builder)	Instantiate a default DeadLetterJdbcConverter based on the given builder.

Method Summary

Modifier and Type	Method	Description
static <E extends EventMessage<?>> DefaultDeadLetterJdbcConverter.Builder<E>	builder()	Instantiate a builder to construct a DefaultDeadLetterJdbcConverter.
JdbcDeadLetter<E>	convertToLetter(ResultSet resultSet)	Converts the given resultSet in an implementation of JdbcDeadLetter.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDeadLetterJdbcConverter

protected DefaultDeadLetterJdbcConverter(DefaultDeadLetterJdbcConverter.Builder<E> builder)

Instantiate a default DeadLetterJdbcConverter based on the given builder.

Will validate whether the generic Serializer and event Serializer are set. If for either this is not the case an AxonConfigurationException is thrown.

Parameters:

builder - The DefaultDeadLetterJdbcConverter.Builder used to instantiate a DefaultDeadLetterJdbcConverter instance.

Method Details

builder

public static <E extends EventMessage<?>>
DefaultDeadLetterJdbcConverter.Builder<E> builder()

Instantiate a builder to construct a DefaultDeadLetterJdbcConverter.

The schema is defaulted to a DeadLetterSchema.defaultSchema(). The generic Serializer and event Serializer are hard requirements and should be provided.

Type Parameters:

E - An implementation of EventMessage contained within the JdbcDeadLetter implementation this converter converts.

Returns:

A builder that con construct a DefaultDeadLetterJdbcConverter.

convertToLetter

public JdbcDeadLetter<E> convertToLetter(ResultSet resultSet)
                                  throws SQLException

Description copied from interface: DeadLetterJdbcConverter

Converts the given resultSet in an implementation of JdbcDeadLetter.

It is recommended to validate the type of EventMessage to place in the result, as different types require additional information to be deserialized and returned.

Specified by:

convertToLetter in interface DeadLetterJdbcConverter<E extends EventMessage<?>,JdbcDeadLetter<E extends EventMessage<?>>>

Parameters:

resultSet - The ResultSet to convert into a JdbcDeadLetter

Returns:

An implementation of JdbcDeadLetter based on the given resultSet.

Throws:

SQLException - if the a columnLabel in the given resultSet does not exist, if a database access error occurs or if the given resultSet is closed.