Package org.codehaus.jackson.map

Examples of org.codehaus.jackson.map.ObjectMapper.writeValue()

383
384
385
386
387
388
389
390
391
392
393
      //The getMethod on this _dbusEventBuffer should be only called by the ConfigLoader
      if(_dbusEventBuffer!=null)
        {
          ObjectMapper mapperDbus = new ObjectMapper();
          StringWriter writerDbus = new StringWriter();
          mapperDbus.writeValue(writerDbus, _dbusEventBuffer);
          jsonObj.put("dbusEventBuffer", new JSONObject(writerDbus.toString()));
        }
      else
        jsonObj.put("dbusEventBuffer", JSONObject.NULL);
View Full Code Here
456
457
458
459
460
461
462
463
464
465
466
  public static PhysicalSourceConfig fromMap(Map<String,Object> map) throws JsonGenerationException, JsonMappingException, IOException
  {

    ObjectMapper mapper = new ObjectMapper();
    StringWriter writer = new StringWriter();
    mapper.writeValue(writer, map);
    String str =  writer.toString();
    return fromString(str);
  }

View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
  public static String generateRegisterResponse(RegisterResponseEntry... entries)
      throws JsonGenerationException, JsonMappingException, IOException
  {
    ObjectMapper mapper = new ObjectMapper();
    StringWriter w = new StringWriter();
    mapper.writeValue(w, entries);
    w.close();
    return w.toString();
  }

  public static String generateRegisterResponseV4(HashMap<String, List<Object>> entries)
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
  public static String generateRegisterResponseV4(HashMap<String, List<Object>> entries)
      throws JsonGenerationException, JsonMappingException, IOException
  {
    ObjectMapper mapper = new ObjectMapper();
    StringWriter w = new StringWriter();
    mapper.writeValue(w, entries);
    w.close();
    return w.toString();
  }

  public static ChannelBuffer streamToChannelBuffer(DbusEventBuffer buf, Checkpoint cp,
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
        else
        {
          LOG.debug("No metadata schema available; sending v4 /register response without.");
        }
        // TODO:  figure out how to retrieve key schemas and include via RegisterResponseEntry.KEY_SCHEMAS_KEY
        mapper.writeValue(out, responseMap);
      }
      else // fall back to old style (v2/v3 response)
      {
        mapper.writeValue(out, registeredSources);
      }
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
        // TODO:  figure out how to retrieve key schemas and include via RegisterResponseEntry.KEY_SCHEMAS_KEY
        mapper.writeValue(out, responseMap);
      }
      else // fall back to old style (v2/v3 response)
      {
        mapper.writeValue(out, registeredSources);
      }

      ChunkedWritableByteChannel responseContent = request.getResponseContent();
      byte[] resultBytes = out.toString().getBytes(Charset.defaultCharset());
      responseContent.addMetadata(DatabusHttpHeaders.DBUS_CLIENT_RELAY_PROTOCOL_VERSION_HDR,
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
  private String mapToJsonStr(Map<String,Object> map) throws JsonGenerationException, JsonMappingException, IOException
  {

    ObjectMapper mapper = new ObjectMapper();
    StringWriter writer = new StringWriter();
    mapper.writeValue(writer, map);
    String str =  writer.toString();
    return str;
  }
 
  @Test
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
    {
      StringWriter out = new StringWriter();
      ObjectMapper objMapper = new ObjectMapper();
      try
      {
        objMapper.writeValue(out, this);
        _jsonString = out.toString();
      }
      catch (Exception e)
      {
        _jsonString = "serialiationError";
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    Collection<LogicalSource> sources = _relay.getSourcesIdNameRegistry().getAllSources();
    if (1 == protoVersion)
    {
      ArrayList<IdNamePair> sourcePairs = new ArrayList<IdNamePair>(sources.size());
      for (LogicalSource source: sources) sourcePairs.add(new IdNamePair(source.getId().longValue(), source.getName()));
      mapper.writeValue(out, sourcePairs);
    }
    else if (2 == protoVersion) mapper.writeValue(out, sources);
    else throw new InvalidRequestParamValueException(COMMAND_NAME, VERSION_PARAM_NAME,
                                                     Integer.toString(protoVersion));
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
    {
      ArrayList<IdNamePair> sourcePairs = new ArrayList<IdNamePair>(sources.size());
      for (LogicalSource source: sources) sourcePairs.add(new IdNamePair(source.getId().longValue(), source.getName()));
      mapper.writeValue(out, sourcePairs);
    }
    else if (2 == protoVersion) mapper.writeValue(out, sources);
    else throw new InvalidRequestParamValueException(COMMAND_NAME, VERSION_PARAM_NAME,
                                                     Integer.toString(protoVersion));


    byte[] resultBytes = out.toString().getBytes(Charset.defaultCharset());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.