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 2014/03/22 00:19:50 UTC
[12/71] [abbrv] fixing STREAMS-26 branch
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProvider.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProvider.java b/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProvider.java
deleted file mode 100644
index 29c0e60..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProvider.java
+++ /dev/null
@@ -1,106 +0,0 @@
-package org.apache.streams.sysomos;
-
-import com.google.common.collect.Lists;
-import com.sysomos.SysomosConfiguration;
-import org.apache.commons.io.IOUtils;
-import org.apache.streams.core.StreamsDatum;
-import org.apache.streams.core.StreamsProvider;
-import org.apache.streams.core.StreamsResultSet;
-import org.joda.time.DateTime;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.StringWriter;
-import java.math.BigInteger;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.util.Arrays;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Queue;
-import java.util.concurrent.*;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
-/**
- * Wrapper for the Sysomos API.
- */
-public class SysomosProvider implements StreamsProvider {
-
- private final static Logger LOGGER = LoggerFactory.getLogger(SysomosProvider.class);
-
- private SysomosConfiguration config;
-
- private List<String> apiKeys;
- private List<ExecutorService> tasks = new LinkedList<ExecutorService>();
- private boolean started = false;
-
- public SysomosProvider(SysomosConfiguration sysomosConfiguration) {
- this.apiKeys = Lists.newArrayList();
- }
-
- public static final String BASE_URL_STRING = "http://api.sysomos.com/";
- private static final String DATE_FORMAT_STRING = "yyyy-MM-dd'T'hh:mm:ssZ";
- private static final String HEARTBEAT_INFO_URL = "http://api.sysomos.com/v1/heartbeat/info?apiKey={api_key}&hid={hid}";
- private static Pattern _pattern = Pattern.compile("code: ([0-9]+)");
-
- public static final int LATENCY = 10;
-
- private String apiKey;
-
- public SysomosConfiguration getConfig() {
- return config;
- }
-
- public void setConfig(SysomosConfiguration config) {
- this.config = config;
- }
-
- protected volatile Queue<StreamsDatum> providerQueue = new ConcurrentLinkedQueue<StreamsDatum>();
-
- SysomosProviderTask task;
- ScheduledExecutorService service;
-
- @Override
- public void start() {
- LOGGER.trace("Starting Producer");
- if(!started) {
- LOGGER.trace("Producer not started. Initializing");
- service = Executors.newScheduledThreadPool(getConfig().getHeartbeatIds().size() + 1);
- for(String heartbeatId : getConfig().getHeartbeatIds()) {
- task = new SysomosProviderTask(this, heartbeatId);
- service.scheduleWithFixedDelay(task, 0, LATENCY, TimeUnit.SECONDS);
- LOGGER.info("Started producer for {} with service {}", getConfig().getApiKey(), service.toString());
- this.tasks.add(service);
- }
- started = true;
- }
- }
-
- @Override
- public void stop() {
- started = false;
- }
-
- @Override
- public Queue<StreamsDatum> getProviderQueue() {
- return providerQueue;
- }
-
- @Override
- public StreamsResultSet readCurrent() {
- return null;
- }
-
- @Override
- public StreamsResultSet readNew(BigInteger bigInteger) {
- return null;
- }
-
- @Override
- public StreamsResultSet readRange(DateTime dateTime, DateTime dateTime2) {
- return null;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProviderTask.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProviderTask.java b/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProviderTask.java
deleted file mode 100644
index f88e1a1..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosProviderTask.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package org.apache.streams.sysomos;
-
-import com.sysomos.SysomosConfiguration;
-import org.apache.commons.io.IOUtils;
-import org.apache.streams.core.StreamsDatum;
-import org.apache.streams.core.StreamsProvider;
-import org.apache.streams.core.StreamsResultSet;
-import org.joda.time.DateTime;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.StringWriter;
-import java.math.BigInteger;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.util.Queue;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
-/**
- * Wrapper for the Sysomos API.
- */
-public class SysomosProviderTask implements Runnable {
-
- private final static Logger LOGGER = LoggerFactory.getLogger(SysomosProviderTask.class);
-
- private SysomosConfiguration config;
-
- private SysomosProvider provider;
-
- private SysomosClient client;
-
- private String heartbeatId;
-
- public SysomosProviderTask(SysomosProvider provider, String heartbeatId) {
- this.provider = provider;
- this.heartbeatId = heartbeatId;
- }
-
- @Override
- public void run() {
-
- client = new SysomosClient(provider.getConfig().getApiKey());
-
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosResponse.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosResponse.java b/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosResponse.java
deleted file mode 100644
index 295045a..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosResponse.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package org.apache.streams.sysomos;
-
-import java.util.Iterator;
-
-/**
- * Created with IntelliJ IDEA.
- * User: rebanks
- * Date: 11/19/13
- * Time: 4:42 PM
- * To change this template use File | Settings | File Templates.
- */
-public interface SysomosResponse extends Iterator<String> {
-
-
- public int getNumResults();
- public boolean hasError();
- public String getErrorMessage();
- public String getXMLResponseString();
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosTagDefinition.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosTagDefinition.java b/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosTagDefinition.java
deleted file mode 100644
index 1f470bf..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/SysomosTagDefinition.java
+++ /dev/null
@@ -1,77 +0,0 @@
-package org.apache.streams.sysomos;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Created with IntelliJ IDEA.
- * User: rebanks
- * Date: 5/1/13
- * Time: 5:01 PM
- * To change this template use File | Settings | File Templates.
- */
-public class SysomosTagDefinition {
-
- private String tagName;
- private String displayName;
- private List<String> queries;
-
- public SysomosTagDefinition(String tagName, String displayName) {
- this.tagName = tagName;
- this.displayName = displayName;
- this.queries = new ArrayList<String>();
- }
-
- public String getTagName() {
- return this.tagName;
- }
-
- public String getDisplayName() {
- return this.displayName;
- }
-
- public List<String> getQueries() {
- List<String> result = new ArrayList<String>();
- result.addAll(this.queries);
- return result;
- }
-
- public void addQuery(String query) {
- this.queries.add(query);
- }
-
- public boolean hasTagName(String tagName) {
- return this.tagName.equals(tagName);
- }
-
- public boolean hasQuery(String query) {
- return this.queries.contains(query);
- }
-
- public boolean hasDisplayName(String displayName) {
- return this.displayName.equals(displayName);
- }
-
- @Override
- public boolean equals(Object o) {
- if(!(o instanceof SysomosTagDefinition)) {
- return false;
- }
- SysomosTagDefinition that = (SysomosTagDefinition) o;
- if(!this.tagName.equals(that.tagName)) {
- return false;
- }
- if(!this.displayName.equals(that.displayName)) {
- return false;
- }
- if(this.queries.size() != that.queries.size()) {
- return false;
- }
- for(int i=0; i < this.queries.size(); ++i) {
- if(!that.queries.contains(this.queries.get(i))) {
- return false;
- }
- }
- return true;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/Sysomos.json
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/Sysomos.json b/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/Sysomos.json
deleted file mode 100644
index 35424a2..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/Sysomos.json
+++ /dev/null
@@ -1,57 +0,0 @@
-{
- "type": "object",
- "$schema": "http://json-schema.org/draft-03/schema",
- "javaType": "com.sysomos.json.Sysomos",
- "id": "#",
- "properties": {
- "tweetJsonLink": {
- "type": "string"
- },
- "location": {
- "properties": {
- "locationString": {
- "type": "string"
- },
- "country": {
- "type": "string"
- }
- }
- },
- "link": {
- "type": "string"
- },
- "twitterFollowing": {
- "type": "string"
- },
- "twitterFollowers": {
- "type": "string"
- },
- "tweetid": {
- "type": "string"
- },
- "mediaType": {
- "type": "string"
- },
- "content": {
- "type": "string"
- },
- "docid": {
- "type": "string"
- },
- "sentiment": {
- "type": "string"
- },
- "time": {
- "type": "string"
- },
- "title": {
- "type": "string"
- },
- "tweetHbLink": {
- "type": "string"
- },
- "influenceLevel": {
- "type": "string"
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/SysomosConfiguration.json
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/SysomosConfiguration.json b/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/SysomosConfiguration.json
deleted file mode 100644
index 7a39d19..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/SysomosConfiguration.json
+++ /dev/null
@@ -1,29 +0,0 @@
-{
- "type": "object",
- "$schema": "http://json-schema.org/draft-03/schema",
- "id": "#",
- "javaType" : "com.sysomos.SysomosConfiguration",
- "properties": {
- "apiKey": {
- "type": "string"
- },
- "endpoint": {
- "type": "string",
- "description": "The endpoint",
- "default": "http://api.sysomos.com/"
- },
- "heartbeatIds": {
- "type": "array",
- "minItems": 1,
- "items": {
- "type": "string"
- }
- },
- "minDelayMs": {
- "type": "long"
- },
- "maxBatchSize": {
- "type": "long"
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/binding.xjb
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/binding.xjb b/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/binding.xjb
deleted file mode 100644
index 0f31d3c..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/binding.xjb
+++ /dev/null
@@ -1,16 +0,0 @@
-<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<jaxb:bindings xmlns:jaxb="http://java.sun.com/xml/ns/jaxb" xmlns:xs="http://www.w3.org/2001/XMLSchema"
- xmlns:xjc="http://java.sun.com/xml/ns/jaxb/xjc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://java.sun.com/xml/ns/jaxb http://java.sun.com/xml/ns/jaxb/bindingschema_2_0.xsd"
- version="2.1">
- <jaxb:globalBindings>
- <!-- Use java.util.Calendar instead of javax.xml.datatype.XMLGregorianCalendar for xs:dateTime -->
- <jaxb:javaType name="java.util.Calendar" xmlType="xs:dateTime"
- parseMethod="javax.xml.bind.DatatypeConverter.parseDateTime"
- printMethod="javax.xml.bind.DatatypeConverter.printDateTime" />
-
- <!-- Force all classes implements Serializable -->
- <xjc:serializable uid="1" />
- </jaxb:globalBindings>
-
-</jaxb:bindings>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/sysomos.xsd
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/sysomos.xsd b/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/sysomos.xsd
deleted file mode 100644
index b41ecfe..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/sysomos.xsd
+++ /dev/null
@@ -1,72 +0,0 @@
-<xs:schema attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="http://www.blogscope.net/api/namespace/schema/SearchResponse" xmlns:xs="http://www.w3.org/2001/XMLSchema">
- <xs:element name="beatApi">
- <xs:complexType>
- <xs:sequence>
- <xs:element name="beatRequest">
- <xs:complexType>
- <xs:sequence>
- <xs:element type="xs:string" name="heatbeatID"/>
- <xs:element type="xs:dateTime" name="startDate"/>
- <xs:element type="xs:dateTime" name="endDate"/>
- <xs:element type="xs:string" name="key"/>
- <xs:element type="xs:short" name="size"/>
- <xs:element type="xs:byte" name="offset"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- <xs:element name="beatResponse">
- <xs:complexType>
- <xs:sequence>
- <xs:element name="beat" maxOccurs="unbounded" minOccurs="0">
- <xs:complexType>
- <xs:sequence>
- <xs:element type="xs:string" name="docid"/>
- <xs:element type="xs:string" name="mediaType"/>
- <xs:element type="xs:dateTime" name="time"/>
- <xs:element type="xs:string" name="title"/>
- <xs:element type="xs:string" name="content"/>
- <xs:element type="xs:anyURI" name="link"/>
- <xs:element type="xs:string" name="gender" minOccurs="0"/>
- <xs:element name="location">
- <xs:complexType>
- <xs:sequence>
- <xs:element type="xs:string" name="country"/>
- <xs:element type="xs:string" name="locationString"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- <xs:element type="xs:string" name="influenceLevel"/>
- <xs:element type="xs:string" name="sentiment"/>
- <xs:element name="tag" maxOccurs="unbounded" minOccurs="0">
- <xs:complexType>
- <xs:sequence>
- <xs:element type="xs:string" name="value"/>
- <xs:element type="xs:string" name="displayName"/>
- <xs:element type="xs:string" name="systemType" minOccurs="0"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- <xs:element type="xs:string" name="tweetid" minOccurs="0"/>
- <xs:element type="xs:anyURI" name="tweetJsonLink" minOccurs="0"/>
- <xs:element type="xs:anyURI" name="tweetHbLink" minOccurs="0"/>
- <xs:element type="xs:string" name="twitterFollowers" minOccurs="0"/>
- <xs:element type="xs:string" name="twitterFollowing" minOccurs="0"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- <xs:element type="xs:short" name="count"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- <xs:element name="errors" maxOccurs="1" minOccurs="0">
- <xs:complexType>
- <xs:sequence>
- <xs:element type="xs:boolean" name="error"/>
- <xs:element type="xs:string" name="errorMessage"/>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
- </xs:sequence>
- </xs:complexType>
- </xs:element>
-</xs:schema>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosJsonSerDeTest.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosJsonSerDeTest.java b/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosJsonSerDeTest.java
deleted file mode 100644
index 889a39f..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosJsonSerDeTest.java
+++ /dev/null
@@ -1,54 +0,0 @@
-package com.sysomos.test;
-
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.sysomos.json.Sysomos;
-import org.junit.Assert;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.BufferedReader;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-
-/**
- * Created with IntelliJ IDEA.
- * User: sblackmon
- * Date: 8/20/13
- * Time: 5:57 PM
- * To change this template use File | Settings | File Templates.
- */
-public class SysomosJsonSerDeTest {
-
- private final static Logger LOGGER = LoggerFactory.getLogger(SysomosJsonSerDeTest.class);
-
- private ObjectMapper mapper = new ObjectMapper();
-
- @Test
- public void Test()
- {
- mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, Boolean.FALSE);
- mapper.configure(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY, Boolean.TRUE);
- mapper.configure(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT, Boolean.TRUE);
-
- InputStream is = SysomosJsonSerDeTest.class.getResourceAsStream("/sysomos_jsons.txt");
- InputStreamReader isr = new InputStreamReader(is);
- BufferedReader br = new BufferedReader(isr);
-
- try {
- while (br.ready()) {
- String line = br.readLine();
- LOGGER.debug(line);
-
- Sysomos ser = mapper.readValue(line, Sysomos.class);
-
- String des = mapper.writeValueAsString(ser);
- LOGGER.debug(des);
- }
- } catch( Exception e ) {
- e.printStackTrace();
- Assert.fail();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosXmlSerDeTest.java
----------------------------------------------------------------------
diff --git a/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosXmlSerDeTest.java b/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosXmlSerDeTest.java
deleted file mode 100644
index 1c549ec..0000000
--- a/trunk/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosXmlSerDeTest.java
+++ /dev/null
@@ -1,85 +0,0 @@
-package com.sysomos.test;
-
-import com.fasterxml.aalto.stax.InputFactoryImpl;
-import com.fasterxml.aalto.stax.OutputFactoryImpl;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.dataformat.xml.JacksonXmlModule;
-import com.fasterxml.jackson.dataformat.xml.XmlFactory;
-import com.fasterxml.jackson.dataformat.xml.XmlMapper;
-import com.sysomos.xml.BeatApi;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.BufferedReader;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-
-/**
- * Created with IntelliJ IDEA.
- * User: sblackmon
- * Date: 8/20/13
- * Time: 5:57 PM
- * To change this template use File | Settings | File Templates.
- */
-public class SysomosXmlSerDeTest {
-
- private final static Logger LOGGER = LoggerFactory.getLogger(SysomosXmlSerDeTest.class);
-
- private XmlMapper xmlMapper;
-
- @Before
- public void Before() {
-
- XmlFactory f = new XmlFactory(new InputFactoryImpl(),
- new OutputFactoryImpl());
-
- JacksonXmlModule module = new JacksonXmlModule();
-
- module.setDefaultUseWrapper(false);
-
- xmlMapper = new XmlMapper(f, module);
-
- xmlMapper
- .configure(
- DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY,
- Boolean.TRUE);
- xmlMapper
- .configure(
- DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT,
- Boolean.TRUE);
- xmlMapper
- .configure(
- DeserializationFeature.USE_JAVA_ARRAY_FOR_JSON_ARRAY,
- Boolean.TRUE);
- xmlMapper.configure(
- DeserializationFeature.READ_ENUMS_USING_TO_STRING,
- Boolean.TRUE);
-
- }
-
- @Test
- public void Test()
- {
- InputStream is = SysomosXmlSerDeTest.class.getResourceAsStream("/sysomos_xmls.txt");
- InputStreamReader isr = new InputStreamReader(is);
- BufferedReader br = new BufferedReader(isr);
-
- try {
- while (br.ready()) {
- String line = br.readLine();
- LOGGER.debug(line);
-
- BeatApi ser = xmlMapper.readValue(line, BeatApi.class);
-
- String des = xmlMapper.writeValueAsString(ser);
- LOGGER.debug(des);
- }
- } catch( Exception e ) {
- e.printStackTrace();
- Assert.fail();
- }
- }
-}