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

Renamed AbstractMessageProducingEndpoint to MessageProducerSupport.

Browse Source
This commit is contained in:
Mark Fisher
2008-11-03 11:52:30 +00:00
parent aa87fa7649
commit 90dcb7e88b
3 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration.event/src/main/java/org/springframework/integration/event/ApplicationEventInboundChannelAdapter.java
View File

@@ -21,7 +21,7 @@ import java.util.concurrent.CopyOnWriteArrayList;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.integration.endpoint.AbstractMessageProducingEndpoint;
import org.springframework.integration.endpoint.MessageProducerSupport;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
@@ -32,7 +32,7 @@ import org.springframework.util.CollectionUtils;
*
* @author Mark Fisher
*/
public class ApplicationEventInboundChannelAdapter extends AbstractMessageProducingEndpoint implements ApplicationListener {
public class ApplicationEventInboundChannelAdapter extends MessageProducerSupport implements ApplicationListener {
private final List<Class<? extends ApplicationEvent>> eventTypes = new CopyOnWriteArrayList<Class<? extends ApplicationEvent>>();

4
org.springframework.integration.mail/src/main/java/org/springframework/integration/mail/ImapIdleChannelAdapter.java
View File

@@ -23,7 +23,7 @@ import javax.mail.internet.MimeMessage;
import org.springframework.context.Lifecycle;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.endpoint.AbstractMessageProducingEndpoint;
import org.springframework.integration.endpoint.MessageProducerSupport;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.util.Assert;
@@ -37,7 +37,7 @@ import org.springframework.util.Assert;
* @author Arjen Poutsma
* @author Mark Fisher
*/
public class ImapIdleChannelAdapter extends AbstractMessageProducingEndpoint implements Lifecycle {
public class ImapIdleChannelAdapter extends MessageProducerSupport implements Lifecycle {
private final IdleTask idleTask = new IdleTask();

6
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageProducingEndpoint.java → org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageProducerSupport.java
View File

@@ -28,7 +28,7 @@ import org.springframework.util.Assert;
*
* @author Mark Fisher
*/
public abstract class AbstractMessageProducingEndpoint extends AbstractEndpoint implements InitializingBean {
public abstract class MessageProducerSupport extends AbstractEndpoint implements InitializingBean {
private volatile MessageChannel outputChannel;
@@ -39,6 +39,10 @@ public abstract class AbstractMessageProducingEndpoint extends AbstractEndpoint
this.outputChannel = outputChannel;
}
public void setSendTimeout(long sendTimeout) {
this.channelTemplate.setSendTimeout(sendTimeout);
}
public void afterPropertiesSet() {
Assert.notNull(this.outputChannel, "outputChannel is required");
}