You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2015/02/17 23:08:04 UTC
[2/2] incubator-streams git commit: refactor uses of new
StreamsJacksonMapper() to use singleton
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/master
Commit: 2a1619587ce8782bad00ebc24b08461879dcb265
Parents: 624d3e1
Author: sblackmon <sb...@apache.org>
Authored: Tue Feb 17 16:01:44 2015 -0600
Committer: sblackmon <sb...@apache.org>
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;