Package org.fudgemsg.mapping

Examples of org.fudgemsg.mapping.FudgeDeserializer

405
406
407
408
409
410
411
412
413
    }
  }

  @Override
  public void messageReceived(final FudgeContext fudgeContext, final FudgeMsgEnvelope msgEnvelope) {
    final FudgeDeserializer deserializer = new FudgeDeserializer(fudgeContext);
    final RemoteCalcNodeMessage message = deserializer.fudgeMsgToObject(RemoteCalcNodeMessage.class, msgEnvelope.getMessage());
    message.accept(_messageVisitor);
  }
View Full Code Here
315
316
317
318
319
320
321
322
    FudgeMsg msg = getFudgeContext().toFudgeMsg(valueSpec).getMessage();
    return getFudgeContext().toByteArray(msg);
  }

  protected ValueSpecification convertByteArrayToSpecification(final byte[] specAsBytes) {
    final FudgeDeserializer deserializer = new FudgeDeserializer(getFudgeContext());
    return deserializer.fudgeMsgToObject(ValueSpecification.class, getFudgeContext().deserialize(specAsBytes).getMessage());
  }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
82
83
   */
  private final class Receiver implements FudgeMessageReceiver {

    @Override
    public void messageReceived(FudgeContext fudgeContext, FudgeMsgEnvelope msgEnvelope) {
      FudgeDeserializer deserializer = new FudgeDeserializer(fudgeContext);
      FudgeMsg msg = msgEnvelope.getMessage();
      MarketDataAvailabilityNotification notification =
          deserializer.fudgeMsgToObject(MarketDataAvailabilityNotification.class, msg);
      s_logger.info("Received notification of market data availability: {}", notification);
      Set<ExternalScheme> schemes = notification.getSchemes();
      notificationReceived(schemes);
    }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
  @Override
  public FunctionBlacklist getBlacklist(final String identifier) {
    ArgumentChecker.notNull(identifier, "identifier");
    try {
      final FudgeDeserializer fdc = new FudgeDeserializer(getFudgeContext());
      final FudgeMsg response = accessRemote(UriBuilder.fromUri(getBaseUri()).path("name/{name}").build(identifier)).get(FudgeMsg.class);
      return createBlacklist(fdc, response);
    } catch (UniformInterfaceException404NotFound e) {
      return null;
    }
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
  @POST
  @Path("add")
  @Consumes(FudgeRest.MEDIA)
  public void add(final FudgeMsg request) {
    final FudgeDeserializer fdc = new FudgeDeserializer(getFudgeContext());
    final Integer ttl = request.getInt(TTL_FIELD);
    final List<FudgeField> fields = request.getAllByName(RULE_FIELD);
    if (fields.size() > 1) {
      final Collection<FunctionBlacklistRule> rules = new ArrayList<FunctionBlacklistRule>(fields.size());
      for (FudgeField field : fields) {
        rules.add(fdc.fieldValueToObject(FunctionBlacklistRule.class, field));
      }
      if (ttl != null) {
        getUnderlying().addBlacklistRules(rules, ttl);
      } else {
        getUnderlying().addBlacklistRules(rules);
      }
    } else if (!fields.isEmpty()) {
      final FunctionBlacklistRule rule = fdc.fieldValueToObject(FunctionBlacklistRule.class, fields.get(0));
      if (ttl != null) {
        getUnderlying().addBlacklistRule(rule, ttl);
      } else {
        getUnderlying().addBlacklistRule(rule);
      }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
  @POST
  @Path("remove")
  @Consumes(FudgeRest.MEDIA)
  public void remove(final FudgeMsg request) {
    final FudgeDeserializer fdc = new FudgeDeserializer(getFudgeContext());
    final List<FudgeField> fields = request.getAllByName(RULE_FIELD);
    if (fields.size() > 1) {
      final Collection<FunctionBlacklistRule> rules = new ArrayList<FunctionBlacklistRule>(fields.size());
      for (FudgeField field : fields) {
        rules.add(fdc.fieldValueToObject(FunctionBlacklistRule.class, field));
      }
      getUnderlying().removeBlacklistRules(rules);
    } else if (!fields.isEmpty()) {
      final FunctionBlacklistRule rule = fdc.fieldValueToObject(FunctionBlacklistRule.class, fields.get(0));
      getUnderlying().removeBlacklistRule(rule);
    }
  }
View Full Code Here
174
175
176
177
178
179
180
181
182
183
      data = loader.findMissingValue(identifier);
      if (data == null) {
        return null;
      }
    }
    final FudgeDeserializer deserializer = new FudgeDeserializer(getFudgeContext());
    final Object obj = deserializeValue(deserializer, data);
    cacheValueSize(specification, data, obj);
    return obj;
  }
View Full Code Here
189
190
191
192
193
194
195
196
197
198
    final boolean isPrivate = filter.isPrivateValue(specification);
    final FudgeMsg data = (isPrivate ? getPrivateDataStore() : getSharedDataStore()).get(identifier);
    if (data == null) {
      return null;
    }
    final FudgeDeserializer deserializer = new FudgeDeserializer(getFudgeContext());
    final Object obj = deserializeValue(deserializer, data);
    cacheValueSize(specification, data, obj);
    return obj;
  }
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
  public Collection<Pair<ValueSpecification, Object>> getValues(final Collection<ValueSpecification> specifications) {
    ArgumentChecker.notNull(specifications, "specifications");
    final Map<ValueSpecification, Long> identifiers = getIdentifierMap().getIdentifiers(specifications);
    final Collection<Pair<ValueSpecification, Object>> returnValues = new ArrayList<Pair<ValueSpecification, Object>>(specifications.size());
    final Collection<Long> identifierValues = identifiers.values();
    final FudgeDeserializer deserializer = new FudgeDeserializer(getFudgeContext());
    Map<Long, FudgeMsg> rawValues = getPrivateDataStore().get(identifierValues);
    if (!rawValues.isEmpty()) {
      final Iterator<Map.Entry<ValueSpecification, Long>> identifierIterator = identifiers.entrySet().iterator();
      while (identifierIterator.hasNext()) {
        final Map.Entry<ValueSpecification, Long> identifier = identifierIterator.next();
View Full Code Here
294
295
296
297
298
299
300
301
302
303
304
        rawValues.put(privateIdentifiers.get(0), data);
      } else {
        rawValues.putAll(getPrivateDataStore().get(privateIdentifiers));
      }
    }
    final FudgeDeserializer deserializer = new FudgeDeserializer(getFudgeContext());
    for (final Map.Entry<ValueSpecification, Long> identifier : identifiers.entrySet()) {
      final FudgeMsg data = rawValues.get(identifier.getValue());
      if (data != null) {
        final Object value = deserializeValue(deserializer, data);
        cacheValueSize(identifier.getKey(), data, value);
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.