INT-1471, more polishing, renamed In/Out adapters to include Receiving/Sending in the class names
This commit is contained in:
@@ -35,13 +35,13 @@ public class TwitterNamespaceHandler extends AbstractIntegrationNamespaceHandler
|
|||||||
registerBeanDefinitionParser("twitter-connection", new ConnectionParser());
|
registerBeanDefinitionParser("twitter-connection", new ConnectionParser());
|
||||||
|
|
||||||
// inbound
|
// inbound
|
||||||
registerBeanDefinitionParser("inbound-update-channel-adapter", new TwitterMessageSourceParser());
|
registerBeanDefinitionParser("inbound-update-channel-adapter", new TwitterReceivingMessageSourceParser());
|
||||||
registerBeanDefinitionParser("inbound-dm-channel-adapter", new TwitterMessageSourceParser());
|
registerBeanDefinitionParser("inbound-dm-channel-adapter", new TwitterReceivingMessageSourceParser());
|
||||||
registerBeanDefinitionParser("inbound-mention-channel-adapter", new TwitterMessageSourceParser());
|
registerBeanDefinitionParser("inbound-mention-channel-adapter", new TwitterReceivingMessageSourceParser());
|
||||||
|
|
||||||
// outbound
|
// outbound
|
||||||
registerBeanDefinitionParser("outbound-update-channel-adapter", new TwitterMessageHandlerParser());
|
registerBeanDefinitionParser("outbound-update-channel-adapter", new TwitterSendingMessageHandlerParser());
|
||||||
registerBeanDefinitionParser("outbound-dm-channel-adapter", new TwitterMessageHandlerParser());
|
registerBeanDefinitionParser("outbound-dm-channel-adapter", new TwitterSendingMessageHandlerParser());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -34,7 +34,7 @@ import org.springframework.integration.config.xml.IntegrationNamespaceUtils;
|
|||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class TwitterMessageSourceParser extends AbstractPollingInboundChannelAdapterParser {
|
public class TwitterReceivingMessageSourceParser extends AbstractPollingInboundChannelAdapterParser {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected BeanMetadataElement parseSource(Element element, ParserContext parserContext) {
|
protected BeanMetadataElement parseSource(Element element, ParserContext parserContext) {
|
||||||
@@ -33,7 +33,7 @@ import org.springframework.integration.config.xml.IntegrationNamespaceUtils;
|
|||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class TwitterMessageHandlerParser extends AbstractOutboundChannelAdapterParser {
|
public class TwitterSendingMessageHandlerParser extends AbstractOutboundChannelAdapterParser {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
|
protected AbstractBeanDefinition parseConsumer(Element element, ParserContext parserContext) {
|
||||||
@@ -30,7 +30,7 @@ import twitter4j.Paging;
|
|||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class DirectMessageMessageSource extends AbstractTwitterMessageSource<DirectMessage> {
|
public class DirectMessageReceivingMessageSource extends AbstractTwitterMessageSource<DirectMessage> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String getComponentType() {
|
public String getComponentType() {
|
||||||
@@ -28,7 +28,7 @@ import twitter4j.Status;
|
|||||||
* @author Josh Long
|
* @author Josh Long
|
||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
*/
|
*/
|
||||||
public class MentionMessageSource extends AbstractTwitterMessageSource<Status> {
|
public class MentionReceivingMessageSource extends AbstractTwitterMessageSource<Status> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String getComponentType() {
|
public String getComponentType() {
|
||||||
@@ -29,7 +29,7 @@ import twitter4j.Status;
|
|||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class TimelineUpdateMessageSource extends AbstractTwitterMessageSource<Status> {
|
public class TimelineUpdateReceivingMessageSource extends AbstractTwitterMessageSource<Status> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String getComponentType() {
|
public String getComponentType() {
|
||||||
@@ -30,7 +30,7 @@ import twitter4j.TwitterException;
|
|||||||
* @author Oleg Zhurakousky
|
* @author Oleg Zhurakousky
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class OutboundDirectMessageMessageHandler extends AbstractOutboundTwitterEndpointSupport {
|
public class DirectMessageSendingMessageHandler extends AbstractOutboundTwitterEndpointSupport {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void handleMessageInternal(Message<?> message) throws Exception {
|
protected void handleMessageInternal(Message<?> message) throws Exception {
|
||||||
@@ -27,7 +27,7 @@ import twitter4j.StatusUpdate;
|
|||||||
* @author Josh Long
|
* @author Josh Long
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
*/
|
*/
|
||||||
public class OutboundTimelineUpdateMessageHandler extends AbstractOutboundTwitterEndpointSupport {
|
public class TimelineUpdateSendingMessageHandler extends AbstractOutboundTwitterEndpointSupport {
|
||||||
@Override
|
@Override
|
||||||
protected void handleMessageInternal(Message<?> message) throws Exception {
|
protected void handleMessageInternal(Message<?> message) throws Exception {
|
||||||
StatusUpdate statusUpdate = this.supportStatusUpdate.fromMessage(message);
|
StatusUpdate statusUpdate = this.supportStatusUpdate.fromMessage(message);
|
||||||
@@ -43,7 +43,7 @@ public class OutboundDirectMessageMessageHandlerTests {
|
|||||||
.setHeader(TwitterHeaders.DISPLAY_COORDINATES, true)
|
.setHeader(TwitterHeaders.DISPLAY_COORDINATES, true)
|
||||||
.setHeader(TwitterHeaders.DM_TARGET_USER_ID, "foo");
|
.setHeader(TwitterHeaders.DM_TARGET_USER_ID, "foo");
|
||||||
|
|
||||||
OutboundDirectMessageMessageHandler handler = new OutboundDirectMessageMessageHandler();
|
DirectMessageSendingMessageHandler handler = new DirectMessageSendingMessageHandler();
|
||||||
handler.setConfiguration(this.getTestConfiguration());
|
handler.setConfiguration(this.getTestConfiguration());
|
||||||
handler.afterPropertiesSet();
|
handler.afterPropertiesSet();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user