MessageMapper is parameterized.
This commit is contained in:
@@ -24,7 +24,7 @@ import org.springframework.integration.message.MessageBuilder;
|
||||
*
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
public class DefaultMessageMapper implements MessageMapper {
|
||||
public class DefaultMessageMapper implements MessageMapper<Object> {
|
||||
|
||||
/**
|
||||
* Returns the Message payload (or null if the Message is null).
|
||||
|
||||
@@ -23,10 +23,10 @@ import org.springframework.integration.message.Message;
|
||||
*
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
public interface MessageMapper {
|
||||
public interface MessageMapper<T> {
|
||||
|
||||
Message<?> toMessage(Object object);
|
||||
Message<?> toMessage(T object);
|
||||
|
||||
Object fromMessage(Message<?> message);
|
||||
T fromMessage(Message<?> message);
|
||||
|
||||
}
|
||||
|
||||
@@ -32,7 +32,7 @@ public class SimpleMessagingGateway extends AbstractMessagingGateway {
|
||||
private volatile MessageMapper messageMapper = new DefaultMessageMapper();
|
||||
|
||||
|
||||
public void setMessageMapper(MessageMapper messageMapper) {
|
||||
public void setMessageMapper(MessageMapper<?> messageMapper) {
|
||||
Assert.notNull(messageMapper, "messageMapper must not be null");
|
||||
this.messageMapper = (messageMapper != null)
|
||||
? messageMapper : new DefaultMessageMapper();
|
||||
|
||||
Reference in New Issue
Block a user