import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messageTemplate() {
	MessagingTemplate messagingTemplate = new MessagingTemplate(outboundRequests());

	messagingTemplate.setReceiveTimeout(60000000l);

	return messagingTemplate;
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Override
protected Map<String, Class<?>> getOptionTypeMappings() {
    Map<String, Class<?>> mappings = super.getOptionTypeMappings();
    mappings.put("messagingTemplate", MessagingTemplate.class);
    mappings.put("channelResolver", DestinationResolver.class);
    return mappings;
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
/**
 * Creates a new MessagePublisherImpl object.
 *
 * @param channel MessageChannel.
 */
public MessagePublisherImpl(MessageChannel channel) {
    super();
    Assert.notNull(channel, "channel cannot be null");
    this.channel = channel;
    this.template = new MessagingTemplate(channel);
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
@StepScope
public PartitionHandler taxCalculationPartitionHandler() {
    MessageChannelPartitionHandler messageChannelPartitionHandler = new MessageChannelPartitionHandler();
    messageChannelPartitionHandler.setGridSize(clusterConfig.getClusterSize() - MASTER_WITHOUT_TAX_CALCULATION_STEP);
    messageChannelPartitionHandler.setReplyChannel(replyChannel());
    messageChannelPartitionHandler.setStepName(EmployeeJobConfigSlave.TAX_CALCULATION_STEP);

    MessagingTemplate messagingGateway = new MessagingTemplate();
    messagingGateway.setReceiveTimeout(RECEIVE_TIMEOUT);
    messagingGateway.setDefaultChannel(outboundRequests());
    messageChannelPartitionHandler.setMessagingOperations(messagingGateway);

    return messageChannelPartitionHandler;
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate() {
	return new MessagingTemplate(channel());
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate() {
	return new MessagingTemplate(tracedChannel());
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean MessagingTemplate messagingTemplate(SleuthSource sleuthSource) {
	return new MessagingTemplate(sleuthSource.output());
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate(){
    return new MessagingTemplate();
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public void setMessagingTemplate(MessagingTemplate messagingTemplate) {
    this.messagingTemplate = messagingTemplate;
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public BookServiceEndPoint() {
    this.messagingTemplate = new MessagingTemplate();
}
 

import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public MyItemProcessor(MessagingTemplate gateway) {
    this.messagingGateway = gateway;
}