Package com.barchart.feed.api.model.meta

Examples of com.barchart.feed.api.model.meta.Instrument

662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
  // ########################

  @Override
  public void make(final Message message) {

    final Instrument instrument = message.getInstrument();

    if (!isValid(instrument)) {
      return;
    }

    MarketDo market = marketMap.get(instrument);

    if (!isValid(market)) {
      register(instrument);
      market = marketMap.get(instrument);

      log.debug("Registering new instrument " + instrument.symbol());
    }

    market.runSafe(safeMake, message);

  }
View Full Code Here
308
309
310
311
312
313
314
315
316
317
318
  // ########################
 
  @Override
  public void make(final Message message) {

    final Instrument instrument = message.getInstrument();

    if (!isValid(instrument)) {
      return;
    }
View Full Code Here
487
488
489
490
491
492
493
494
495
496
497
    listenerList.remove(listener);
  }

  protected final void notifyRegListeners(final MarketDo market) {

    final Instrument inst = market.instrument();

    final Set<MarketEvent> events = market.regEvents();

    for (final MarketRegListener listener : listenerList) {
      try {
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
    final CharSequence queryPage = query.type.queryPage;

    final CharSequence username = settings.getAuthUser();
    final CharSequence password = settings.getAuthPass();

    final Instrument instrument = query.instrument;
    final CharSequence symbol = formatHistorical(instrument.symbol());  // TODO Need to modify symbol

    final DateTimeZone timeZone = DateTimeZone.forOffsetMillis(
        (int)instrument.timeZoneOffset());
    final CharSequence start = requestTime(query.timeStart, timeZone);
    final CharSequence end = requestTime(query.timeEnd, timeZone);

    final CharSequence maxRecords = query.maxRecords <= 0 ? "" : ""
        + query.maxRecords;
View Full Code Here
167
168
169
170
171
172
173
174
175
176
    if (instrument == null) {
      return Collections.emptyList();
    }

    Instrument inst = ObjectMapFactory.build(InstrumentDDF.class, instrument);
   
    return Collections.singletonList(inst);
   
  }
View Full Code Here
310
311
312
313
314
315
316
317
318
319
320
321
      assert index == entryCount;

    }

    final Instrument instrument = getInstrument();
    setExchange(DDF_Exchange.fromCode(instrument.exchangeCode().getBytes()[0]));

    final long millisUTC = xmlTimeDecode(getExchange().kind.time.zone, tag,
        TIME_LAST, XML_PASS);
    setDecodeDefaults(millisUTC);
View Full Code Here
53
54
55
56
57
58
59
60
61
    /** make an upper case id */
    final TextValue lookup = lookupFromSymbol(ValueBuilder.newText(symbol.toString()));

    final Map<Tag, Object> map = new HashMap<Tag, Object>();
    map.put(InstrumentField.MARKET_GUID, lookup);
    final Instrument instrument = ObjectMapFactory.build(InstrumentDDF.class, map);

    return Collections.singletonList(instrument);
  }
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
      assert index == entryCount;

    }

    final Instrument instrument = getInstrument();
   
    // FIXME This doesnt work, instrument uses the exchange() method to get it's exchange
    // so you can't call exchangeCode() on instrument before it's been set in the message;
    setExchange(DDF_Exchange.fromCode(instrument.exchangeCode().getBytes()[0]));

    final long millisUTC = xmlTimeDecode(getExchange().kind.time.zone, tag,
        TIME_LAST, XML_PASS);
    setDecodeDefaults(millisUTC);
View Full Code Here
148
149
150
151
152
153
154
155
156
157
158
    final String stringURL = urlQuery(settings, query);
    log.debug("stringURL : \n\t {}", stringURL);

    final Builder builder = Builder.from(query.type);

    final Instrument instrument = query.instrument;

    final E entryReference = (E) builder.newEntry(0, null, instrument);

    final Result<E> result = new Result<E>(query, entryReference, listener);
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
77
78
    final CharSequence queryPage = query.type.queryPage;

    final CharSequence username = settings.getAuthUser();
    final CharSequence password = settings.getAuthPass();

    final Instrument instrument = query.instrument;
    final CharSequence symbol = instrument.vendorSymbols().get(VendorID.BARCHART_HISTORICAL);

    final DateTimeZone timeZone = DateTimeZone.forID(instrument.timeZoneName());
    final CharSequence start = requestTime(query.timeStart, timeZone);
    final CharSequence end = requestTime(query.timeEnd, timeZone);

    final CharSequence maxRecords =
        query.maxRecords <= 0 ? "" : "" + query.maxRecords;
View Full Code Here
TOP

Related Classes of com.barchart.feed.api.model.meta.Instrument

  • com.barchart.feed.base.provider.MakerBase
  • com.barchart.feed.base.provider.MakerBaseAllMarkets
  • com.barchart.feed.base.provider.MarketplaceBase
  • com.barchart.feed.base.provider.MarketplaceBase$BaseAgent
  • com.barchart.feed.base.provider.MarketProviderBase
  • com.barchart.feed.base.provider.MarketProviderBase$BaseAgent
  • com.barchart.feed.ddf.historical.provider.CodecHelper
  • com.barchart.feed.ddf.historical.provider.DDF_HistoricalService
  • com.barchart.feed.ddf.instrument.provider.DDF_InstrumentProvider
  • com.barchart.feed.ddf.instrument.provider.ServiceBasicDDF
    • 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.