Class MessageRowMapper
java.lang.Object
org.springframework.integration.jdbc.store.channel.MessageRowMapper
- All Implemented Interfaces:
org.springframework.jdbc.core.RowMapper<org.springframework.messaging.Message<?>>
public class MessageRowMapper
extends Object
implements org.springframework.jdbc.core.RowMapper<org.springframework.messaging.Message<?>>
Convenience class to be used to unpack a
Message from a result set
row. Uses column named in the result set to extract the required data, so
that select clause ordering is unimportant.- Since:
- 2.2
-
Constructor Summary
ConstructorsConstructorDescriptionMessageRowMapper(org.springframework.integration.support.converter.AllowListDeserializingConverter deserializer, org.springframework.jdbc.support.lob.LobHandler lobHandler) Construct an instance based on the providedAllowListDeserializingConverterandLobHandler. -
Method Summary
-
Constructor Details
-
MessageRowMapper
public MessageRowMapper(org.springframework.integration.support.converter.AllowListDeserializingConverter deserializer, org.springframework.jdbc.support.lob.LobHandler lobHandler) Construct an instance based on the providedAllowListDeserializingConverterandLobHandler.- Parameters:
deserializer- theAllowListDeserializingConverterto use.lobHandler- theLobHandlerto use.
-
-
Method Details
-
mapRow
public org.springframework.messaging.Message<?> mapRow(ResultSet rs, int rowNum) throws SQLException - Specified by:
mapRowin interfaceorg.springframework.jdbc.core.RowMapper<org.springframework.messaging.Message<?>>- Throws:
SQLException
-