|
20 | 20 | import java.util.Queue; |
21 | 21 | import java.util.concurrent.ConcurrentLinkedQueue; |
22 | 22 |
|
23 | | -import org.apache.commons.logging.Log; |
24 | | -import org.apache.commons.logging.LogFactory; |
25 | | - |
26 | | -import org.springframework.beans.factory.BeanFactory; |
27 | 23 | import org.springframework.integration.core.MessageSource; |
28 | 24 | import org.springframework.integration.endpoint.AbstractMessageSource; |
29 | | -import org.springframework.integration.support.DefaultMessageBuilderFactory; |
30 | | -import org.springframework.integration.support.MessageBuilderFactory; |
31 | | -import org.springframework.integration.support.utils.IntegrationUtils; |
32 | 25 | import org.springframework.messaging.Message; |
33 | 26 | import org.springframework.messaging.MessagingException; |
34 | 27 | import org.springframework.util.Assert; |
|
46 | 39 | */ |
47 | 40 | public class MailReceivingMessageSource extends AbstractMessageSource<Object> { |
48 | 41 |
|
49 | | - private final Log logger = LogFactory.getLog(this.getClass()); |
50 | | - |
51 | 42 | private final MailReceiver mailReceiver; |
52 | 43 |
|
53 | 44 | private final Queue<Object> mailQueue = new ConcurrentLinkedQueue<>(); |
54 | 45 |
|
55 | | - private BeanFactory beanFactory; |
56 | | - |
57 | | - private MessageBuilderFactory messageBuilderFactory = new DefaultMessageBuilderFactory(); |
58 | | - |
59 | | - private boolean messageBuilderFactorySet; |
60 | | - |
61 | | - private String beanName; |
62 | | - |
63 | 46 |
|
64 | 47 | public MailReceivingMessageSource(MailReceiver mailReceiver) { |
65 | 48 | Assert.notNull(mailReceiver, "mailReceiver must not be null"); |
66 | 49 | this.mailReceiver = mailReceiver; |
67 | 50 | } |
68 | 51 |
|
69 | | - @Override |
70 | | - public final void setBeanFactory(BeanFactory beanFactory) { |
71 | | - this.beanFactory = beanFactory; |
72 | | - } |
73 | | - |
74 | | - protected BeanFactory getBeanFactory() { |
75 | | - return this.beanFactory; |
76 | | - } |
77 | | - |
78 | | - protected MessageBuilderFactory getMessageBuilderFactory() { |
79 | | - if (!this.messageBuilderFactorySet) { |
80 | | - if (this.beanFactory != null) { |
81 | | - this.messageBuilderFactory = IntegrationUtils.getMessageBuilderFactory(this.beanFactory); |
82 | | - } |
83 | | - this.messageBuilderFactorySet = true; |
84 | | - } |
85 | | - return this.messageBuilderFactory; |
86 | | - } |
87 | | - |
88 | | - @Override |
89 | | - public String getComponentName() { |
90 | | - return this.beanName; |
91 | | - } |
92 | | - |
93 | 52 | @Override |
94 | 53 | public String getComponentType() { |
95 | 54 | return "mail:inbound-channel-adapter"; |
96 | 55 | } |
97 | 56 |
|
98 | | - @Override |
99 | | - public void setBeanName(String name) { |
100 | | - this.beanName = name; |
101 | | - } |
102 | | - |
103 | 57 | @Override |
104 | 58 | protected Object doReceive() { |
105 | 59 | try { |
|
0 commit comments