Repository: incubator-streams Updated Branches: refs/heads/blueprints 5f133579d -> 40fa8c015
these changes should go in a separate PR ensure ObjectType is set Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/40fa8c01 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/40fa8c01 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/40fa8c01 Branch: refs/heads/blueprints Commit: 40fa8c0158732ad59ee6fe62493f6fed328f4125 Parents: 5f13357 Author: Steve Blackmon <[email protected]> Authored: Mon Oct 27 09:07:40 2014 -0500 Committer: Steve Blackmon <[email protected]> Committed: Mon Oct 27 09:07:40 2014 -0500 ---------------------------------------------------------------------- .../twitter/processor/TwitterTypeConverter.java | 18 +++++++++++++----- .../serializer/util/TwitterActivityUtil.java | 2 +- 2 files changed, 14 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/40fa8c01/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java index 804aa14..5495174 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java @@ -28,12 +28,10 @@ import org.apache.streams.core.StreamsDatum; import org.apache.streams.core.StreamsProcessor; import org.apache.streams.exceptions.ActivitySerializerException; import org.apache.streams.pojo.json.Activity; -import org.apache.streams.twitter.pojo.Delete; -import org.apache.streams.twitter.pojo.Retweet; -import org.apache.streams.twitter.pojo.Tweet; -import org.apache.streams.twitter.pojo.UserstreamEvent; +import org.apache.streams.twitter.pojo.*; import org.apache.streams.twitter.provider.TwitterEventClassifier; -import org.apache.streams.twitter.serializer.*; +import org.apache.streams.twitter.serializer.StreamsTwitterMapper; +import org.apache.streams.twitter.serializer.TwitterJsonActivitySerializer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -81,6 +79,16 @@ public class TwitterTypeConverter implements StreamsProcessor { Object result = null; + if ( inClass.equals( FriendList.class )) { + LOGGER.debug("FRIENDLIST"); + return null; + } + + if ( inClass.equals( UserstreamEvent.class )) { + LOGGER.debug("USERSTREAMEVENT"); + return null; + } + if( outClass.equals( Activity.class )) { LOGGER.debug("ACTIVITY"); result = twitterJsonActivitySerializer.deserialize( http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/40fa8c01/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/util/TwitterActivityUtil.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/util/TwitterActivityUtil.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/util/TwitterActivityUtil.java index 56b7005..470f201 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/util/TwitterActivityUtil.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/util/TwitterActivityUtil.java @@ -191,7 +191,7 @@ public class TwitterActivityUtil { .or(Optional.of(user.getId().toString())) .orNull() )); - + actor.setObjectType("page"); actor.setDisplayName(user.getName()); actor.setAdditionalProperty("handle", user.getScreenName()); actor.setSummary(user.getDescription());
