Package org.fudgemsg.mapping

Examples of org.fudgemsg.mapping.FudgeDeserializer

65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
  }

  protected <T> T cycleGenericObject(final Class<T> clazz, final T object) {
    s_logger.info("object {}", object);
    final FudgeSerializer fudgeSerializationContext = new FudgeSerializer(getFudgeContext());
    final FudgeDeserializer fudgeDeserializationContext = new FudgeDeserializer(getFudgeContext());
    final MutableFudgeMsg messageIn = fudgeSerializationContext.newMessage();
    fudgeSerializationContext.addToMessageWithClassHeaders(messageIn, "test", null, object, clazz);
    s_logger.info("message {}", messageIn);
    final FudgeMsg messageOut = cycleMessage(messageIn);
    s_logger.info("message {}", messageOut);
    final T newObject = fudgeDeserializationContext.fieldValueToObject(clazz, messageOut.getByName("test"));
    assertNotNull(newObject);
    s_logger.info("object {}", newObject);
    assertTrue(clazz.isAssignableFrom(newObject.getClass()));
    return newObject;
  }
View Full Code Here
37
38
39
40
41
42
43
44
  @Override
  public void messageReceived(FudgeContext fudgeContext, FudgeMsgEnvelope msgEnvelope) {
    // TODO kirk 2012-08-13 -- Check schema version.
    FudgeMsg msg = msgEnvelope.getMessage();
    LiveDataValueUpdateBean updateBean = LiveDataValueUpdateBeanFudgeBuilder.fromFudgeMsg(new FudgeDeserializer(fudgeContext), msg);
    getLiveDataServer().liveDataReceived(updateBean);
  }
View Full Code Here
70
71
72
73
74
75
76
77
78
  //-------------------------------------------------------------------------
  @Override
  public byte[] requestReceived(byte[] message) {
    FudgeMsgEnvelope requestEnvelope = getFudgeContext().deserialize(message);
    FudgeDeserializer deserializationContext = new FudgeDeserializer(getFudgeContext());
    FudgeMsg responseContainer = getUnderlying().requestReceived(deserializationContext, requestEnvelope);
    return getFudgeContext().toByteArray(responseContainer);
  }
View Full Code Here
67
68
69
70
71
72
73
74
    FudgeMsgReader reader = new FudgeMsgReader(new FudgeXMLStreamReader(getFudgeContext(), entityReader));
    FudgeMsg message = reader.nextMessage();
    if (message == null) {
      return null;
    }
    FudgeDeserializer deser = new FudgeDeserializer(getFudgeContext());
    return deser.fudgeMsgToObject(type, message);
  }
View Full Code Here
63
64
65
66
67
68
69
70
    FudgeMsgReader reader = new FudgeMsgReader(new FudgeJSONStreamReader(getFudgeContext(), entityReader));
    FudgeMsg message = reader.nextMessage();
    if (message == null) {
      return null;
    }
    FudgeDeserializer deser = new FudgeDeserializer(getFudgeContext());
    return deser.fudgeMsgToObject(type, message);
  }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
    return result;
  }

  //-------------------------------------------------------------------------
  public void save(ReferenceData securityResult) {
    FudgeDeserializer deserializer = new FudgeDeserializer(_fudgeContext);
   
    String securityDes = securityResult.getIdentifier();
    FudgeMsg fieldData = securityResult.getFieldValues();
   
    if (securityDes != null && fieldData != null) {
View Full Code Here
58
59
60
61
62
63
64
65
    FudgeMsgReader reader = new FudgeMsgReader(new FudgeDataInputStreamReader(getFudgeContext(), entityStream));
    FudgeMsg message = reader.nextMessage();
    if (message == null) {
      return null;
    }
    FudgeDeserializer deser = new FudgeDeserializer(getFudgeContext());
    return deser.fudgeMsgToObject(type, message);
  }
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
    private void dispatch(final FudgeMsgEnvelope envelope) {
      FudgeMsg response = null;
      try {
        s_logger.debug("Received message with {} fields. Dispatching to underlying.", envelope.getMessage().getNumFields());
        response = getUnderlying().requestReceived(new FudgeDeserializer(_fudgeContext), envelope);
      } catch (Exception e) {
        s_logger.warn("Unable to dispatch message to underlying receiver", e);
        return;
      }
      if (response != null) {
View Full Code Here
43
44
45
46
47
48
49
50
51
52
    MutableFudgeMsg inputMsg = serializationContext.objectToFudgeMsg(inputConfig);
    FudgeMsg outputMsg = s_fudgeContext.deserialize(s_fudgeContext.toByteArray(inputMsg)).getMessage();
    assertNotNull(outputMsg);
    assertEquals(3, outputMsg.getNumFields());
   
    FudgeDeserializer deserializationContext = new FudgeDeserializer(s_fudgeContext);
    HistoricalTimeSeriesRating outputConfig = deserializationContext.fudgeMsgToObject(HistoricalTimeSeriesRating.class, outputMsg);
   
    assertEquals(inputConfig, outputConfig);
  }
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
346
      return null;
    }

    @Override
    public void messageReceived(final FudgeContext fudgeContext, final FudgeMsgEnvelope msgEnvelope) {
      final FudgeDeserializer deserializer = new FudgeDeserializer(fudgeContext);
      final CacheMessage request = deserializer.fudgeMsgToObject(CacheMessage.class, msgEnvelope.getMessage());
      CacheMessage response = request.accept(this);
      if (response == null) {
        if (request.getCorrelationId() != null) {
          response = new CacheMessage();
        }
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.