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

Moved MessageChannelTemplate and AsyncMessageChannelTemplate to the 'channel' package (was in 'message').

Browse Source
This commit is contained in:
Mark Fisher
2008-09-24 13:50:31 +00:00
parent 648ae40605
commit de10530387
8 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
org.springframework.integration/src/main/java/org/springframework/integration/message/AsyncMessageChannelTemplate.java → org.springframework.integration/src/main/java/org/springframework/integration/channel/AsyncMessageChannelTemplate.java
View File

@@ -14,14 +14,14 @@
* limitations under the License.
*/
package org.springframework.integration.message;
package org.springframework.integration.channel;
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.message.AsyncMessage;
import org.springframework.integration.message.Message;
import org.springframework.util.Assert;
/**

7
org.springframework.integration/src/main/java/org/springframework/integration/message/MessageChannelTemplate.java → org.springframework.integration/src/main/java/org/springframework/integration/channel/MessageChannelTemplate.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.integration.message;
package org.springframework.integration.channel;
import java.util.List;
import java.util.concurrent.CountDownLatch;
@@ -24,9 +24,8 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.channel.BlockingChannel;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.selector.MessageSelector;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionStatus;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java
View File

@@ -24,7 +24,7 @@ import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.ConfigurationException;
import org.springframework.integration.channel.ChannelRegistry;
import org.springframework.integration.channel.ChannelRegistryAware;
import org.springframework.integration.message.MessageChannelTemplate;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.message.MessagingException;
import org.springframework.integration.scheduling.TaskScheduler;
import org.springframework.integration.scheduling.TaskSchedulerAware;

2
org.springframework.integration/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java
View File

@@ -17,7 +17,7 @@
package org.springframework.integration.gateway;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.message.MessageChannelTemplate;
import org.springframework.integration.channel.MessageChannelTemplate;
/**
* A convenient base class providing access to a {@link MessageChannelTemplate} and exposing setter methods for

7
org.springframework.integration/src/test/java/org/springframework/integration/message/MessageChannelTemplateTests.java → org.springframework.integration/src/test/java/org/springframework/integration/channel/MessageChannelTemplateTests.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.integration.message;
package org.springframework.integration.channel;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
@@ -29,9 +29,10 @@ import org.junit.Test;
import org.springframework.context.support.GenericApplicationContext;
import org.springframework.integration.bus.DefaultMessageBus;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.endpoint.AbstractMessageHandlingEndpoint;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.StringMessage;
/**
* @author Mark Fisher