refactor uses of new StreamsJacksonMapper() to use singleton
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/2a161958 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/2a161958 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/2a161958 Branch: refs/heads/asf-master Commit: 2a1619587ce8782bad00ebc24b08461879dcb265 Parents: 624d3e1 Author: sblackmon <[email protected]> Authored: Tue Feb 17 16:01:44 2015 -0600 Committer: sblackmon <[email protected]> Committed: Tue Feb 17 16:01:44 2015 -0600 ---------------------------------------------------------------------- .../apache/streams/converter/BaseObjectNodeActivityConverter.java | 2 +- .../org/apache/streams/converter/BaseStringActivityConverter.java | 2 +- .../streams/converter/test/BaseActivityConverterProcessorTest.java | 2 +- .../converter/test/CustomActivityConverterProcessorTest.java | 2 +- .../converter/test/NoConfigActivityConverterProcessorTest.java | 2 +- .../src/main/java/org/apache/streams/s3/S3PersistWriter.java | 2 +- .../src/main/java/org/apache/streams/json/JsonPathExtractor.java | 2 +- .../src/main/java/org/apache/streams/json/JsonPathFilter.java | 2 +- .../apache/streams/facebook/processor/FacebookTypeConverter.java | 2 +- .../streams/facebook/provider/FacebookFriendFeedProvider.java | 2 +- .../streams/facebook/provider/FacebookFriendUpdatesProvider.java | 2 +- .../streams/facebook/provider/FacebookUserInformationProvider.java | 2 +- .../streams/facebook/provider/FacebookUserstreamProvider.java | 2 +- .../java/com/google/gplus/processor/GooglePlusTypeConverter.java | 2 +- .../com/google/gplus/serializer/util/GPlusCommentDeserializer.java | 2 +- .../com/google/gplus/serializer/util/GPlusEventClassifier.java | 2 +- .../com/google/gplus/serializer/util/GPlusPersonDeserializer.java | 2 +- .../src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java | 2 +- .../src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java | 2 +- .../com/google/gplus/processor/GooglePlusActivitySerDeTest.java | 2 +- .../com/google/gplus/processor/GooglePlusTypeConverterTest.java | 2 +- .../apache/streams/rss/serializer/SyndEntryActivitySerializer.java | 2 +- .../apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java | 2 +- .../apache/streams/twitter/processor/TwitterEventProcessor.java | 2 +- .../twitter/serializer/TwitterJsonUserActivitySerializer.java | 2 +- .../src/main/java/com/youtube/processor/YoutubeTypeConverter.java | 2 +- .../main/java/com/youtube/serializer/YoutubeEventClassifier.java | 2 +- .../test/java/com/youtube/processor/YoutubeTypeConverterTest.java | 2 +- .../test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java | 2 +- .../apache/streams/monitoring/tasks/BroadcastMonitorThread.java | 2 +- .../org/apache/streams/jackson/MemoryUsageDeserializerTest.java | 2 +- .../apache/streams/dropwizard/test/GenericWebhookResourceTest.java | 2 +- .../main/java/org/apache/streams/local/tasks/BaseStreamsTask.java | 2 +- 33 files changed, 33 insertions(+), 33 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java index a6d2bd5..b6cde29 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java @@ -41,7 +41,7 @@ public class BaseObjectNodeActivityConverter implements ActivityConverter<Object public static Class requiredClass = ObjectNode.class; - private ObjectMapper mapper = new StreamsJacksonMapper(); + private ObjectMapper mapper = StreamsJacksonMapper.getInstance(); @Override public Class requiredClass() { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java index ced1c7a..7438abb 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java @@ -42,7 +42,7 @@ public class BaseStringActivityConverter implements ActivityConverter<String> { public static Class requiredClass = String.class; - private ObjectMapper mapper = new StreamsJacksonMapper(); + private ObjectMapper mapper = StreamsJacksonMapper.getInstance(); @Override public Class requiredClass() { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/BaseActivityConverterProcessorTest.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/BaseActivityConverterProcessorTest.java b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/BaseActivityConverterProcessorTest.java index 97a52a4..f680764 100644 --- a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/BaseActivityConverterProcessorTest.java +++ b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/BaseActivityConverterProcessorTest.java @@ -41,7 +41,7 @@ import static junit.framework.Assert.*; */ public class BaseActivityConverterProcessorTest { - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ACTIVITY_JSON = "{\"id\":\"id\",\"published\":\"Tue Jan 17 21:21:46 Z 2012\",\"verb\":\"post\",\"provider\":{\"id\":\"providerid\"}}"; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/CustomActivityConverterProcessorTest.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/CustomActivityConverterProcessorTest.java b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/CustomActivityConverterProcessorTest.java index c9333c7..89ad571 100644 --- a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/CustomActivityConverterProcessorTest.java +++ b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/CustomActivityConverterProcessorTest.java @@ -41,7 +41,7 @@ import static junit.framework.Assert.*; */ public class CustomActivityConverterProcessorTest { - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); ActivityConverterProcessor processor; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/NoConfigActivityConverterProcessorTest.java ---------------------------------------------------------------------- diff --git a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/NoConfigActivityConverterProcessorTest.java b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/NoConfigActivityConverterProcessorTest.java index 9c5b128..a25f5cf 100644 --- a/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/NoConfigActivityConverterProcessorTest.java +++ b/streams-components/streams-converters/src/test/java/org/apache/streams/converter/test/NoConfigActivityConverterProcessorTest.java @@ -41,7 +41,7 @@ import static junit.framework.Assert.*; */ public class NoConfigActivityConverterProcessorTest { - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ACTIVITY_JSON = "{\"id\":\"id\",\"published\":\"Tue Jan 17 21:21:46 Z 2012\",\"verb\":\"post\",\"provider\":{\"id\":\"providerid\"}}"; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java index ad09b32..09f16ff 100644 --- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java +++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java @@ -254,7 +254,7 @@ public class S3PersistWriter implements StreamsPersistWriter, DatumStatusCountab try { // if the user has chosen to not set the object mapper, then set a default object mapper for them. if (this.objectMapper == null) - this.objectMapper = new StreamsJacksonMapper(); + this.objectMapper = StreamsJacksonMapper.getInstance(); // Create the credentials Object if (this.amazonS3Client == null) { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java b/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java index 99c1856..3aa5216 100644 --- a/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java +++ b/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java @@ -46,7 +46,7 @@ public class JsonPathExtractor implements StreamsProcessor { private final static Logger LOGGER = LoggerFactory.getLogger(JsonPathExtractor.class); - private ObjectMapper mapper = new StreamsJacksonMapper(); + private ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private String pathExpression; private JsonPath jsonPath; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java b/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java index b8c10ab..55dbda4 100644 --- a/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java +++ b/streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java @@ -51,7 +51,7 @@ public class JsonPathFilter implements StreamsProcessor { private final static Logger LOGGER = LoggerFactory.getLogger(JsonPathFilter.class); - private ObjectMapper mapper = new StreamsJacksonMapper(); + private ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private String pathExpression; private JsonPath jsonPath; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java index 362ec10..98e7a91 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java @@ -196,7 +196,7 @@ public class FacebookTypeConverter implements StreamsProcessor { @Override public void prepare(Object o) { - mapper = new StreamsJacksonMapper(); + mapper = StreamsJacksonMapper.getInstance(); facebookPageActivitySerializer = new FacebookPageActivitySerializer(); facebookPostActivitySerializer = new FacebookPostActivitySerializer(); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendFeedProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendFeedProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendFeedProvider.java index 1c50a62..2e577e4 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendFeedProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendFeedProvider.java @@ -57,7 +57,7 @@ public class FacebookFriendFeedProvider implements StreamsProvider, Serializable public static final String STREAMS_ID = "FacebookFriendFeedProvider"; private static final Logger LOGGER = LoggerFactory.getLogger(FacebookFriendFeedProvider.class); - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ALL_PERMISSIONS = "ads_management,ads_read,create_event,create_note,email,export_stream,friends_about_me,friends_actions.books,friends_actions.music,friends_actions.news,friends_actions.video,friends_activities,friends_birthday,friends_education_history,friends_events,friends_games_activity,friends_groups,friends_hometown,friends_interests,friends_likes,friends_location,friends_notes,friends_online_presence,friends_photo_video_tags,friends_photos,friends_questions,friends_relationship_details,friends_relationships,friends_religion_politics,friends_status,friends_subscriptions,friends_videos,friends_website,friends_work_history,manage_friendlists,manage_notifications,manage_pages,photo_upload,publish_actions,publish_stream,read_friendlists,read_insights,read_mailbox,read_page_mailboxes,read_requests,read_stream,rsvp_event,share_item,sms,status_update,user_about_me,user_actions.books,user_actions.music,user_actions.news,user_actions.video,user_activitie s,user_birthday,user_education_history,user_events,user_friends,user_games_activity,user_groups,user_hometown,user_interests,user_likes,user_location,user_notes,user_online_presence,user_photo_video_tags,user_photos,user_questions,user_relationship_details,user_relationships,user_religion_politics,user_status,user_subscriptions,user_videos,user_website,user_work_history,video_upload,xmpp_login"; private FacebookUserstreamConfiguration configuration; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendUpdatesProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendUpdatesProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendUpdatesProvider.java index 387a8e5..bc10f9b 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendUpdatesProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookFriendUpdatesProvider.java @@ -58,7 +58,7 @@ public class FacebookFriendUpdatesProvider implements StreamsProvider, Serializa public static final String STREAMS_ID = "FacebookFriendPostsProvider"; private static final Logger LOGGER = LoggerFactory.getLogger(FacebookFriendUpdatesProvider.class); - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ALL_PERMISSIONS = "ads_management,ads_read,create_event,create_note,email,export_stream,friends_about_me,friends_actions.books,friends_actions.music,friends_actions.news,friends_actions.video,friends_activities,friends_birthday,friends_education_history,friends_events,friends_games_activity,friends_groups,friends_hometown,friends_interests,friends_likes,friends_location,friends_notes,friends_online_presence,friends_photo_video_tags,friends_photos,friends_questions,friends_relationship_details,friends_relationships,friends_religion_politics,friends_status,friends_subscriptions,friends_videos,friends_website,friends_work_history,manage_friendlists,manage_notifications,manage_pages,photo_upload,publish_actions,publish_stream,read_friendlists,read_insights,read_mailbox,read_page_mailboxes,read_requests,read_stream,rsvp_event,share_item,sms,status_update,user_about_me,user_actions.books,user_actions.music,user_actions.news,user_actions.video,user_activitie s,user_birthday,user_education_history,user_events,user_friends,user_games_activity,user_groups,user_hometown,user_interests,user_likes,user_location,user_notes,user_online_presence,user_photo_video_tags,user_photos,user_questions,user_relationship_details,user_relationships,user_religion_politics,user_status,user_subscriptions,user_videos,user_website,user_work_history,video_upload,xmpp_login"; private FacebookUserstreamConfiguration configuration; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserInformationProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserInformationProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserInformationProvider.java index 35d4f4b..9649627 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserInformationProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserInformationProvider.java @@ -53,7 +53,7 @@ public class FacebookUserInformationProvider implements StreamsProvider, Seriali public static final String STREAMS_ID = "FacebookUserInformationProvider"; private static final Logger LOGGER = LoggerFactory.getLogger(FacebookUserInformationProvider.class); - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ALL_PERMISSIONS = "ads_management,ads_read,create_event,create_note,email,export_stream,friends_about_me,friends_actions.books,friends_actions.music,friends_actions.news,friends_actions.video,friends_activities,friends_birthday,friends_education_history,friends_events,friends_games_activity,friends_groups,friends_hometown,friends_interests,friends_likes,friends_location,friends_notes,friends_online_presence,friends_photo_video_tags,friends_photos,friends_questions,friends_relationship_details,friends_relationships,friends_religion_politics,friends_status,friends_subscriptions,friends_videos,friends_website,friends_work_history,manage_friendlists,manage_notifications,manage_pages,photo_upload,publish_actions,publish_stream,read_friendlists,read_insights,read_mailbox,read_page_mailboxes,read_requests,read_stream,rsvp_event,share_item,sms,status_update,user_about_me,user_actions.books,user_actions.music,user_actions.news,user_actions.video,user_activitie s,user_birthday,user_education_history,user_events,user_friends,user_games_activity,user_groups,user_hometown,user_interests,user_likes,user_location,user_notes,user_online_presence,user_photo_video_tags,user_photos,user_questions,user_relationship_details,user_relationships,user_religion_politics,user_status,user_subscriptions,user_videos,user_website,user_work_history,video_upload,xmpp_login"; private FacebookUserInformationConfiguration facebookUserInformationConfiguration; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserstreamProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserstreamProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserstreamProvider.java index 829ecc1..fc324a1 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserstreamProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/FacebookUserstreamProvider.java @@ -61,7 +61,7 @@ public class FacebookUserstreamProvider implements StreamsProvider, Serializable public static final String STREAMS_ID = "FacebookUserstreamProvider"; private static final Logger LOGGER = LoggerFactory.getLogger(FacebookUserstreamProvider.class); - private static final ObjectMapper mapper = new StreamsJacksonMapper(); + private static final ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ALL_PERMISSIONS = "read_stream"; private FacebookUserstreamConfiguration configuration; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java index 73e261f..0ec1eb8 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java @@ -114,7 +114,7 @@ public class GooglePlusTypeConverter implements StreamsProcessor { @Override public void prepare(Object configurationObject) { googlePlusActivityUtil = new GooglePlusActivityUtil(); - mapper = new StreamsJacksonMapper(); + mapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Person.class, new GPlusPersonDeserializer()); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusCommentDeserializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusCommentDeserializer.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusCommentDeserializer.java index 513bdc7..956309a 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusCommentDeserializer.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusCommentDeserializer.java @@ -52,7 +52,7 @@ public class GPlusCommentDeserializer extends JsonDeserializer<Comment> { public Comment deserialize(JsonParser jsonParser, DeserializationContext deserializationContext) throws IOException, JsonProcessingException { JsonNode node = jsonParser.getCodec().readTree(jsonParser); - ObjectMapper objectMapper = new StreamsJacksonMapper(); + ObjectMapper objectMapper = StreamsJacksonMapper.getInstance(); Comment comment = new Comment(); try { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusEventClassifier.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusEventClassifier.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusEventClassifier.java index 2866b5b..3dfac33 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusEventClassifier.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusEventClassifier.java @@ -30,7 +30,7 @@ import java.io.IOException; import java.io.Serializable; public class GPlusEventClassifier implements Serializable { - private static ObjectMapper mapper = new StreamsJacksonMapper(); + private static ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String ACTIVITY_IDENTIFIER = "\"plus#activity\""; private static final String PERSON_IDENTIFIER = "\"plus#person\""; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusPersonDeserializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusPersonDeserializer.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusPersonDeserializer.java index 7ee3990..179f148 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusPersonDeserializer.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/serializer/util/GPlusPersonDeserializer.java @@ -53,7 +53,7 @@ public class GPlusPersonDeserializer extends JsonDeserializer<Person> { */ @Override public Person deserialize(JsonParser jsonParser, DeserializationContext deserializationContext) throws IOException, JsonProcessingException { - ObjectMapper m = new StreamsJacksonMapper(); + ObjectMapper m = StreamsJacksonMapper.getInstance(); JsonNode node = jsonParser.getCodec().readTree(jsonParser); Person person = new Person(); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java index 9fea22c..ae2f918 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusCommentSerDeTest.java @@ -50,7 +50,7 @@ public class GooglePlusCommentSerDeTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Comment.class, new GPlusCommentDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java index 6f6b2e3..103d16d 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/GooglePlusPersonSerDeTest.java @@ -48,7 +48,7 @@ public class GooglePlusPersonSerDeTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Person.class, new GPlusPersonDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusActivitySerDeTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusActivitySerDeTest.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusActivitySerDeTest.java index 6babea0..6aeeb99 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusActivitySerDeTest.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusActivitySerDeTest.java @@ -48,7 +48,7 @@ public class GooglePlusActivitySerDeTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(com.google.api.services.plus.model.Activity.class, new GPlusActivityDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusTypeConverterTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusTypeConverterTest.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusTypeConverterTest.java index a8a44c0..c219ff5 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusTypeConverterTest.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/com/google/gplus/processor/GooglePlusTypeConverterTest.java @@ -51,7 +51,7 @@ public class GooglePlusTypeConverterTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Person.class, new GPlusPersonDeserializer()); simpleModule.addDeserializer(com.google.api.services.plus.model.Activity.class, new GPlusActivityDeserializer()); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntryActivitySerializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntryActivitySerializer.java b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntryActivitySerializer.java index 566b009..a993830 100644 --- a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntryActivitySerializer.java +++ b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntryActivitySerializer.java @@ -219,7 +219,7 @@ public class SyndEntryActivitySerializer implements ActivitySerializer<ObjectNod * @return */ private Activity addRomeExtension(Activity activity, ObjectNode entry) { - ObjectMapper mapper = new StreamsJacksonMapper(); + ObjectMapper mapper = StreamsJacksonMapper.getInstance(); ObjectNode activityRoot = mapper.convertValue(activity, ObjectNode.class); ObjectNode extensions = JsonNodeFactory.instance.objectNode(); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-rss/src/test/java/org/apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-rss/src/test/java/org/apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java b/streams-contrib/streams-provider-rss/src/test/java/org/apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java index fd9a996..d0e1afb 100644 --- a/streams-contrib/streams-provider-rss/src/test/java/org/apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java +++ b/streams-contrib/streams-provider-rss/src/test/java/org/apache/streams/rss/test/SyndEntryActivitySerizlizerTest.java @@ -41,7 +41,7 @@ import static org.junit.Assert.assertTrue; public class SyndEntryActivitySerizlizerTest { - private static ObjectMapper mapper = new StreamsJacksonMapper(); + private static ObjectMapper mapper = StreamsJacksonMapper.getInstance(); @Test public void testJsonData() throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java index 976a27d..c570da8 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java @@ -186,7 +186,7 @@ public class TwitterEventProcessor implements StreamsProcessor { @Override public void prepare(Object configurationObject) { - mapper = new StreamsJacksonMapper(); + mapper = StreamsJacksonMapper.getInstance(); twitterJsonActivitySerializer = new TwitterJsonActivitySerializer(); } http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonUserActivitySerializer.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonUserActivitySerializer.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonUserActivitySerializer.java index 1bf935c..4e6979b 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonUserActivitySerializer.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonUserActivitySerializer.java @@ -55,7 +55,7 @@ public class TwitterJsonUserActivitySerializer implements ActivitySerializer<Str @Override public Activity deserialize(String event) throws ActivitySerializerException { - ObjectMapper mapper = new StreamsJacksonMapper(); + ObjectMapper mapper = StreamsJacksonMapper.getInstance(); User user = null; try { user = mapper.readValue(event, User.class); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java b/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java index a99fef1..2c10ebd 100644 --- a/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java +++ b/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/processor/YoutubeTypeConverter.java @@ -97,7 +97,7 @@ public class YoutubeTypeConverter implements StreamsProcessor { @Override public void prepare(Object o) { youtubeActivityUtil = new YoutubeActivityUtil(); - mapper = new StreamsJacksonMapper(); + mapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Video.class, new YoutubeVideoDeserializer()); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/serializer/YoutubeEventClassifier.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/serializer/YoutubeEventClassifier.java b/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/serializer/YoutubeEventClassifier.java index 08c5b09..62c673b 100644 --- a/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/serializer/YoutubeEventClassifier.java +++ b/streams-contrib/streams-provider-youtube/src/main/java/com/youtube/serializer/YoutubeEventClassifier.java @@ -28,7 +28,7 @@ import org.apache.streams.jackson.StreamsJacksonMapper; import java.io.IOException; public class YoutubeEventClassifier { - private static ObjectMapper mapper = new StreamsJacksonMapper(); + private static ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final String VIDEO_IDENTIFIER = "\"youtube#video\""; public static Class detectClass(String json) { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/processor/YoutubeTypeConverterTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/processor/YoutubeTypeConverterTest.java b/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/processor/YoutubeTypeConverterTest.java index 4a0d78e..8b53776 100644 --- a/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/processor/YoutubeTypeConverterTest.java +++ b/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/processor/YoutubeTypeConverterTest.java @@ -45,7 +45,7 @@ public class YoutubeTypeConverterTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Video.class, new YoutubeVideoDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java b/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java index 382a4ca..652571c 100644 --- a/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java +++ b/streams-contrib/streams-provider-youtube/src/test/java/com/youtube/serializer/YoutubeVideoSerDeTest.java @@ -46,7 +46,7 @@ public class YoutubeVideoSerDeTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(Video.class, new YoutubeVideoDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java ---------------------------------------------------------------------- diff --git a/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java b/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java index 948863e..59f779f 100644 --- a/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java +++ b/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java @@ -83,7 +83,7 @@ public class BroadcastMonitorThread extends NotificationBroadcasterSupport imple * POJOs which are generated from JSON schemas */ private void initializeObjectMapper() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(MemoryUsageBroadcast.class, new MemoryUsageDeserializer()); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-monitoring/src/test/java/org/apache/streams/jackson/MemoryUsageDeserializerTest.java ---------------------------------------------------------------------- diff --git a/streams-monitoring/src/test/java/org/apache/streams/jackson/MemoryUsageDeserializerTest.java b/streams-monitoring/src/test/java/org/apache/streams/jackson/MemoryUsageDeserializerTest.java index c0ba7fb..5fdad16 100644 --- a/streams-monitoring/src/test/java/org/apache/streams/jackson/MemoryUsageDeserializerTest.java +++ b/streams-monitoring/src/test/java/org/apache/streams/jackson/MemoryUsageDeserializerTest.java @@ -40,7 +40,7 @@ public class MemoryUsageDeserializerTest { @Before public void setup() { - objectMapper = new StreamsJacksonMapper(); + objectMapper = StreamsJacksonMapper.getInstance(); SimpleModule simpleModule = new SimpleModule(); simpleModule.addDeserializer(MemoryUsageBroadcast.class, new MemoryUsageDeserializer()); objectMapper.registerModule(simpleModule); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-runtimes/streams-runtime-dropwizard/src/test/java/org/apache/streams/dropwizard/test/GenericWebhookResourceTest.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-dropwizard/src/test/java/org/apache/streams/dropwizard/test/GenericWebhookResourceTest.java b/streams-runtimes/streams-runtime-dropwizard/src/test/java/org/apache/streams/dropwizard/test/GenericWebhookResourceTest.java index db9133b..8db7073 100644 --- a/streams-runtimes/streams-runtime-dropwizard/src/test/java/org/apache/streams/dropwizard/test/GenericWebhookResourceTest.java +++ b/streams-runtimes/streams-runtime-dropwizard/src/test/java/org/apache/streams/dropwizard/test/GenericWebhookResourceTest.java @@ -33,7 +33,7 @@ import static org.mockito.Mockito.*; */ public class GenericWebhookResourceTest { - private static ObjectMapper mapper = new StreamsJacksonMapper(); + private static ObjectMapper mapper = StreamsJacksonMapper.getInstance(); private static final GenericWebhookResource genericWebhookResource = new GenericWebhookResource(); http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2a161958/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/BaseStreamsTask.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/BaseStreamsTask.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/BaseStreamsTask.java index 907bce3..c0c7ea6 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/BaseStreamsTask.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/BaseStreamsTask.java @@ -52,7 +52,7 @@ public abstract class BaseStreamsTask implements StreamsTask { private String streamIdentifier; public BaseStreamsTask(Map<String, Object> config) { - this.mapper = new StreamsJacksonMapper(); + this.mapper = StreamsJacksonMapper.getInstance(); this.mapper.registerSubtypes(Activity.class); this.streamConfig = config;
