Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-684 AbstractMessageHandler now implements Ordered

Browse Source
This commit is contained in:
Mark Fisher
2009-06-25 21:35:25 +00:00
parent 517d424d8b
commit 91ffae8a33
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractMessageHandler.java
View File

@@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2008 the original author or authors. * Copyright 2002-2009 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@@ -19,6 +19,7 @@ package org.springframework.integration.handler;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.springframework.core.Ordered;
import org.springframework.integration.core.Message; import org.springframework.integration.core.Message;
import org.springframework.integration.core.MessagingException; import org.springframework.integration.core.MessagingException;
import org.springframework.integration.message.MessageHandler; import org.springframework.integration.message.MessageHandler;
@@ -33,10 +34,20 @@ import org.springframework.util.Assert;
* *
* @author Mark Fisher * @author Mark Fisher
*/ */
public abstract class AbstractMessageHandler implements MessageHandler { public abstract class AbstractMessageHandler implements MessageHandler, Ordered {
protected final Log logger = LogFactory.getLog(this.getClass()); protected final Log logger = LogFactory.getLog(this.getClass());
private volatile int order = Ordered.LOWEST_PRECEDENCE;
public void setOrder(int order) {
this.order = order;
}
public int getOrder() {
return this.order;
}
public final void handleMessage(Message<?> message) { public final void handleMessage(Message<?> message) {
Assert.notNull(message == null, "Message must not be null"); Assert.notNull(message == null, "Message must not be null");