本文整理汇总了Java中org.springframework.integration.core.MessagingTemplate类的典型用法代码示例。如果您正苦于以下问题:Java MessagingTemplate类的具体用法?Java MessagingTemplate怎么用?Java MessagingTemplate使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MessagingTemplate类属于org.springframework.integration.core包,在下文中一共展示了MessagingTemplate类的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: messageTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messageTemplate() {
MessagingTemplate messagingTemplate = new MessagingTemplate(outboundRequests());
messagingTemplate.setReceiveTimeout(60000000l);
return messagingTemplate;
}
开发者ID:mminella,项目名称:java-remote-partitioning,代码行数:9,代码来源:JobConfiguration.java
示例2: getOptionTypeMappings
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;
}
开发者ID:christophd,项目名称:citrus-admin,代码行数:8,代码来源:ChannelEndpointConverter.java
示例3: MessagePublisherImpl
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);
}
开发者ID:cucina,项目名称:opencucina,代码行数:12,代码来源:MessagePublisherImpl.java
示例4: taxCalculationPartitionHandler
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;
}
开发者ID:cegeka,项目名称:batchers,代码行数:16,代码来源:EmployeeJobConfigMaster.java
示例5: messagingTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate() {
return new MessagingTemplate(channel());
}
开发者ID:reshmik,项目名称:Zipkin,代码行数:5,代码来源:TraceChannelInterceptorTests.java
示例6: messagingTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate() {
return new MessagingTemplate(tracedChannel());
}
开发者ID:spring-cloud,项目名称:spring-cloud-sleuth,代码行数:5,代码来源:TraceChannelInterceptorTests.java
示例7: messagingTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean MessagingTemplate messagingTemplate(SleuthSource sleuthSource) {
return new MessagingTemplate(sleuthSource.output());
}
开发者ID:spring-cloud,项目名称:spring-cloud-sleuth,代码行数:4,代码来源:TraceIgnoringChannelInterceptorTests.java
示例8: messagingTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
@Bean
public MessagingTemplate messagingTemplate(){
return new MessagingTemplate();
}
开发者ID:mrFlick72,项目名称:socialDocumentLibrary,代码行数:5,代码来源:MessagingConfig.java
示例9: setMessagingTemplate
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public void setMessagingTemplate(MessagingTemplate messagingTemplate) {
this.messagingTemplate = messagingTemplate;
}
开发者ID:mrFlick72,项目名称:socialDocumentLibrary,代码行数:4,代码来源:BookServiceEndpoint.java
示例10: BookServiceEndPoint
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public BookServiceEndPoint() {
this.messagingTemplate = new MessagingTemplate();
}
开发者ID:mrFlick72,项目名称:socialDocumentLibrary,代码行数:4,代码来源:BookServiceEndPoint.java
示例11: MyItemProcessor
import org.springframework.integration.core.MessagingTemplate; //导入依赖的package包/类
public MyItemProcessor(MessagingTemplate gateway) {
this.messagingGateway = gateway;
}
开发者ID:osnircunha,项目名称:SpringFrameworkSamples,代码行数:4,代码来源:MyItemProcessor.java
注:本文中的org.springframework.integration.core.MessagingTemplate类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论