Package org.fudgemsg.mapping

Examples of org.fudgemsg.mapping.FudgeDeserializer

38
39
40
41
42
43
44
45
46
47
48
49
  public UniqueId locateOrStore(final TempTarget target) {
    final URI uri = DataTempTargetRepositoryResource.uriLocateOrStore(getBaseUri());
    try {
      final FudgeContext context = getFudgeContext();
      final FudgeSerializer fsc = new FudgeSerializer(context);
      final FudgeDeserializer fdc = new FudgeDeserializer(context);
      final FudgeMsg response = accessRemote(uri).post(FudgeMsg.class, FudgeSerializer.addClassHeader(fsc.objectToFudgeMsg(target), target.getClass(), TempTarget.class));
      return fdc.fudgeMsgToObject(UniqueId.class, response);
    } catch (final UniformInterfaceException404NotFound e) {
      return null;
    }
  }
View Full Code Here
51
52
53
54
55
56
57
58
59
  @POST
  @Path("target")
  @Consumes(FudgeRest.MEDIA)
  public Response locateOrStore(final FudgeMsg request) {
    final FudgeContext context = OpenGammaFudgeContext.getInstance();
    final TempTarget target = new FudgeDeserializer(context).fudgeMsgToObject(TempTarget.class, request);
    final UniqueId uid = getUnderlying().locateOrStore(target);
    return responseOk(new FudgeSerializer(context).objectToFudgeMsg(uid));
  }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
  @Override
  public TempTarget get(final UniqueId identifier) {
    final URI uri = DataTempTargetSourceResource.uriGet(getBaseUri(), identifier);
    try {
      final FudgeDeserializer fdc = new FudgeDeserializer(getFudgeContext());
      final FudgeMsg response = accessRemote(uri).get(FudgeMsg.class);
      return fdc.fudgeMsgToObject(TempTarget.class, response);
    } catch (final UniformInterfaceException404NotFound e) {
      return null;
    }
  }
View Full Code Here
41
42
43
44
45
46
47
    assertNull(VersionCorrectionFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), null));
    assertNotNull(VersionCorrectionFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), sample));
  }

  public void test_fromFudgeMsg() {
    assertNull(VersionCorrectionFudgeBuilder.fromFudgeMsg(new FudgeDeserializer(OpenGammaFudgeContext.getInstance()), null));
  }
View Full Code Here
34
35
36
37
38
39
40
    assertNull(ExternalIdBundleFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), null));
    assertNotNull(ExternalIdBundleFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), sample));
  }

  public void test_fromFudgeMsg() {
    assertNull(ExternalIdBundleFudgeBuilder.fromFudgeMsg(new FudgeDeserializer(OpenGammaFudgeContext.getInstance()), null));
  }
View Full Code Here
53
54
55
56
57
58
59
    assertNull(UniqueIdFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), null));
    assertNotNull(UniqueIdFudgeBuilder.toFudgeMsg(new FudgeSerializer(OpenGammaFudgeContext.getInstance()), sample));
  }

  public void test_fromFudgeMsg() {
    assertNull(UniqueIdFudgeBuilder.fromFudgeMsg(new FudgeDeserializer(OpenGammaFudgeContext.getInstance()), null));
  }
View Full Code Here
59
60
61
62
63
64
65
  }

  @Test(expectedExceptions = RuntimeException.class)
  public void test_fromFudgeMsg_empty() {
    FudgeMsg msg = getFudgeContext().newMessage();
    assertNull(UniqueIdFudgeBuilder.fromFudgeMsg(new FudgeDeserializer(OpenGammaFudgeContext.getInstance()), msg));
  }
View Full Code Here
159
160
161
162
163
164
165
166
167
  @Override
  public void messageReceived(FudgeContext fudgeContext, FudgeMsgEnvelope msgEnvelope) {
    final FudgeMsg msg = msgEnvelope.getMessage();
    s_logger.debug("Received change message {}", msg);
    final FudgeDeserializer deserializer = new FudgeDeserializer(fudgeContext);
    final ChangeEvent event = deserializer.fudgeMsgToObject(ChangeEvent.class, msg);
    fireEntityChanged(event);
  }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
  }

  @SuppressWarnings("unchecked")
  private <R> Collection<ConfigItem<R>> configItemCollectionResult(final FudgeMsg msg) {
    final Collection<ConfigItem<R>> result = Lists.newArrayListWithCapacity(msg.getNumFields());
    final FudgeDeserializer deserializer = new FudgeDeserializer(OpenGammaFudgeContext.getInstance());
    for (final FudgeField field : msg) {
      result.add(deserializer.fieldValueToObject(ConfigItem.class, field));
    }
    return result;
  }
View Full Code Here
218
219
220
221
222
223
224
225
  private static byte[] toByteArray(final FudgeMsg msg) {
    return s_fudgeContext.toByteArray(msg);
  }

  private static TempTarget fromByteArray(final byte[] data) {
    final FudgeDeserializer deserializer = new FudgeDeserializer(s_fudgeContext);
    return deserializer.fudgeMsgToObject(TempTarget.class, s_fudgeContext.deserialize(data).getMessage());
  }
View Full Code Here
TOP

Related Classes of org.fudgemsg.mapping.FudgeDeserializer

  • com.opengamma.bbg.config.BloombergSecurityTypeDefinitionFudgeEncodingTest
  • com.opengamma.bbg.referencedata.cache.MongoDBReferenceDataCache
  • com.opengamma.bbg.replay.TicksPlayerJob
  • com.opengamma.bbg.server.SecurityMasterRequestReceiver
  • com.opengamma.core.change.JmsChangeManager
  • com.opengamma.core.config.impl.RemoteConfigSource
  • com.opengamma.core.historicaltimeseries.impl.DataHistoricalTimeSeriesSourceResource
  • com.opengamma.engine.cache.BerkeleyDBIdentifierMap
  • com.opengamma.engine.cache.DefaultViewComputationCache
  • com.opengamma.engine.cache.FudgeMessageStoreServer$MessageHandler
    • Copyright © 2018 www.massapicom. 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.