在每个子上下文中,您可以添加标头丰富器以将自定义标头设置为来自适配器的 URL;输出通道是共享服务的共享通道。
在服务中,使用void foo(Message emailMessage, @Header("myHeader") String url)
我通常建议使用单个服务,除非该服务需要根据源执行完全不同的操作。
EDIT:
我修改了对您之前问题的回答,以使用标题中的 url 来增强原始消息;每个实例都有自己的标头丰富器,并且它们都将丰富的消息路由到公共emailChannel
.
@Configuration
@EnableIntegration
public class GeneralImapAdapter {
@Value("${imap.url}")
String imapUrl;
@Bean
public static PropertySourcesPlaceholderConfigurer pspc() {
return new PropertySourcesPlaceholderConfigurer();
}
@Bean
@InboundChannelAdapter(value = "enrichHeadersChannel", poller = @Poller(fixedDelay = "10000") )
public MessageSource<javax.mail.Message> mailMessageSource(MailReceiver imapMailReceiver) {
return new MailReceivingMessageSource(imapMailReceiver);
}
@Bean
public MessageChannel enrichHeadersChannel() {
return new DirectChannel();
}
@Bean
@Transformer(inputChannel="enrichHeadersChannel", outputChannel="emailChannel")
public HeaderEnricher enrichHeaders() {
Map<String, ? extends HeaderValueMessageProcessor<?>> headersToAdd =
Collections.singletonMap("emailUrl", new StaticHeaderValueMessageProcessor<>(this.imapUrl));
HeaderEnricher enricher = new HeaderEnricher(headersToAdd);
return enricher;
}
@Bean
public MailReceiver imapMailReceiver() {
MailReceiver receiver = mock(MailReceiver.class);
Message message = mock(Message.class);
when(message.toString()).thenReturn("Message from " + this.imapUrl);
Message[] messages = new Message[] {message};
try {
when(receiver.receive()).thenReturn(messages);
}
catch (MessagingException e) {
e.printStackTrace();
}
return receiver;
}
}
...我修改了接收服务,以便它可以访问标头...
@MessageEndpoint
public class EmailReceiverService {
@ServiceActivator(inputChannel="emailChannel")
public void handleMessage(Message message, @Header("emailUrl") String url) {
System.out.println(message + " header:" + url);
}
}
...希望有帮助。
EDIT 2:
这个有点复杂;它从有效负载中提取内容并将其放入标头中;由于您有完整的消息,因此您的用例不需要它,但它说明了该技术......
@Bean
@Transformer(inputChannel="enrichHeadersChannel", outputChannel="emailChannel")
public HeaderEnricher enrichHeaders() {
Map<String, HeaderValueMessageProcessor<?>> headersToAdd = new HashMap<>();
headersToAdd.put("emailUrl", new StaticHeaderValueMessageProcessor<String>(this.imapUrl));
Expression expression = new SpelExpressionParser().parseExpression("payload.from[0].toString()");
headersToAdd.put("from", new ExpressionEvaluatingHeaderValueMessageProcessor<>(expression, String.class));
HeaderEnricher enricher = new HeaderEnricher(headersToAdd);
return enricher;
}
and
@ServiceActivator(inputChannel="emailChannel")
public void handleMessage(Message message, @Header("emailUrl") String url,
@Header("from") String from) {
System.out.println(message + " header:" + url + " from:" + from);
}