com.google.common.collect.ClassToInstanceMap的实例源码

项目:FinanceAnalytics    文件:ComponentMapProvider.java   
@Override
public ComponentMap get() {

  ClassToInstanceMap<Object> components = MutableClassToInstanceMap.create();

  components.putInstance(HolidaySource.class,_holidaySource);
  components.putInstance(ConfigSource.class,_configSource);
  components.putInstance(HistoricalTimeSeriesSource.class,_htsSource);
  components.putInstance(ConventionBundleSource.class,_conventionBundleSource);
  components.putInstance(HistoricalTimeSeriesResolver.class,_htsResolver);
  components.putInstance(SecuritySource.class,_securitySource);
  components.putInstance(ConventionSource.class,_conventionSource);
  components.putInstance(RegionSource.class,_regionSource);
  components.putInstance(PositionSource.class,_positionSource);
  components.putInstance(MarketDataSnapshotSource.class,_snapshotSource);
  components.putInstance(LegalEntitySource.class,_legalEntitySource);
  components.putInstance(ExchangeSource.class,_exchangeSource);

  ComponentMap componentMap = ComponentMap.of(components);
  ServiceContext serviceContext = ServiceContext.of(componentMap.getComponents())
      .with(VersionCorrectionProvider.class,new FixedInstantVersionCorrectionProvider(Instant.now()));
  ThreadLocalServiceContext.init(serviceContext);

  return componentMap;
}
项目:java-util-examples    文件:ClassToInstanceMapExample.java   
@Test
public void classToINstanceMap_example () {

    Person person = new Person("Jackson");
    Jobs jobs = new Jobs("IT person");
    Address address = new  Address("505 Williams Street");

    ClassToInstanceMap<Object> classToInstanceMap = MutableClassToInstanceMap.create();
    classToInstanceMap.put(Person.class,person);
    classToInstanceMap.put(Jobs.class,jobs);
    classToInstanceMap.put(Address.class,address);

    logger.info(classToInstanceMap);

    assertEquals("IT person",classToInstanceMap.getInstance(Jobs.class).getJobName());
}
项目:bazel    文件:BuildConfiguration.java   
/**
 * Returns a copy of this configuration only including the given fragments (which the current
 * configuration is assumed to have).
 */
public BuildConfiguration clone(
    FragmentClassSet fragmentClasses,RuleClassProvider ruleClassProvider) {

  ClassToInstanceMap<Fragment> fragmentsMap = MutableClassToInstanceMap.create();
  for (Fragment fragment : fragments.values()) {
    if (fragmentClasses.fragmentClasses().contains(fragment.getClass())) {
      fragmentsMap.put(fragment.getClass(),fragment);
    }
  }
  BuildOptions options = buildOptions.trim(
      getOptionsClasses(fragmentsMap.keySet(),ruleClassProvider));
  BuildConfiguration newConfig =
      new BuildConfiguration(
          directories,fragmentsMap,options,mainRepositoryName.strippedName());
  return newConfig;
}
项目:levelup-java-examples    文件:ClassToInstanceMapExample.java   
@Test
public void classToINstanceMap_example () {

    Person person = new Person("Jackson");
    Jobs jobs = new Jobs("IT person");
    Address address = new  Address("505 Williams Street");

    ClassToInstanceMap<Object> classToInstanceMap = MutableClassToInstanceMap.create();
    classToInstanceMap.put(Person.class,classToInstanceMap.getInstance(Jobs.class).getJobName());
}
项目:rigel    文件:HighlightField.java   
private List<String> getHighlights(ClassToInstanceMap<FieldDataSource<?>> context) {
    QueryResponse response = context.getInstance(QueryResponseDataSource.class).get();
    Schema<?> schema = context.getInstance(SchemaDataSource.class).get();

    String docId = schema.id.getField().getValue(context);
    if (docId == null) {
        return null;
    }
    Map<String,Map<String,List<String>>> hilighting = response.getHighlighting();
    if (hilighting == null) {
        return null;
    }
    Map<String,List<String>> hilightingForDoc =  hilighting.get(docId);
    if (hilightingForDoc == null) {
        return null;
    }
    return hilightingForDoc.get(getFieldName());
}
项目:GitHub    文件:StaticEnvironment.java   
static <T extends Completable> T getInstance(Class<T> type,Supplier<T> supplier) {
  ClassToInstanceMap<Completable> components = state().components;
  @Nullable T instance = components.getInstance(type);
  if (instance == null) {
    instance = supplier.get();
    components.putInstance(type,instance);
  }
  return instance;
}
项目:guava-demo    文件:ClassToInstanceSample.java   
public static void main(String[] args) {
    ClassToInstanceMap<Number> numbers = MutableClassToInstanceMap.create();

    numbers.putInstance(Integer.class,Integer.valueOf(0));
    numbers.putInstance(Double.class,Double.valueOf(1));
    numbers.putInstance(Float.class,Float.valueOf(3));

    double myNum = numbers.getInstance(Double.class);
    System.out.println(myNum);
}
项目:tensorics-core    文件:Coordinates.java   
/**
 * Creates a class to instance map,from the given coordinates. The map will contain the classes of the coordinates
 * as keys and the coordinates themselves as values. Duplicate keys (dimensions) are not allowed and will result in
 * an {@link IllegalArgumentException}.
 * 
 * @param coordinates the coordinates to be added to the map
 * @return an immutable map from dimensions (coordinate classes) to coordinate
 * @throws IllegalArgumentException if more than one coordinate per dimension are provided
 * @deprecated
 */
@Deprecated
public static <C> ClassToInstanceMap<C> mapOf(Iterable<? extends C> coordinates) {
    ImmutableClassToInstanceMap.Builder<C> coordinateBuilder = ImmutableClassToInstanceMap.builder();
    for (C coordinate : coordinates) {
        @SuppressWarnings("unchecked")
        Class<C> coordinateClass = (Class<C>) coordinate.getClass();
        coordinateBuilder.put(coordinateClass,coordinate);
    }
    return coordinateBuilder.build();
}
项目:tensorics-core    文件:ImmutableOptionRegistry.java   
private <T1 extends Option<T1>> ImmutableOptionRegistry(Collection<T> options) {
    /*
     * we first have to create a mutable map,because the collection might contain options of the same class,where
     * later ones will override previous ones. This would not be allowed by the builder of the immutable map.
     */
    ClassToInstanceMap<T> mutableOptions = MutableClassToInstanceMap.create();
    addToMap(mutableOptions,options);
    this.options = ImmutableClassToInstanceMap.copyOf(mutableOptions);
}
项目:tensorics-core    文件:ImmutableOptionRegistry.java   
private void addToMap(ClassToInstanceMap<T> mutableMap,Collection<T> toAdd) {
    for (T option : toAdd) {
        @SuppressWarnings("unchecked")
        Class<T> markerInterface = (Class<T>) option.getMarkerInterface();
        mutableMap.putInstance(markerInterface,option);
    }
}
项目:sette-tool    文件:SetteAnnotationUtils.java   
/**
 * Gets the map of SETTE annotations.
 *
 * @param element
 *            an annotated element
 * @return a map of SETTE annotations
 */
public static ClassToInstanceMap<Annotation> getSetteAnnotations(
        @NonNull AnnotatedElement element) {
    ClassToInstanceMap<Annotation> setteAnnots = MutableClassToInstanceMap.create();

    Arrays.stream(element.getAnnotations())
            .filter(SetteAnnotationUtils::isSetteAnnotation)
            .forEach(a -> setteAnnots.put(a.annotationType(),a));

    return setteAnnots;
}
项目:error-prone    文件:PlaceholderMethod.java   
static PlaceholderMethod create(
    CharSequence name,UType returnType,ImmutableMap<UVariableDecl,ImmutableClassToInstanceMap<Annotation>> parameters,ClassToInstanceMap<Annotation> annotations) {
  final boolean allowsIdentity = annotations.getInstance(Placeholder.class).allowsIdentity();
  final Class<? extends Matcher<? super ExpressionTree>> matchesClass =
      annotations.containsKey(Matches.class)
          ? UTemplater.getValue(annotations.getInstance(Matches.class))
          : null;
  final Class<? extends Matcher<? super ExpressionTree>> notMatchesClass =
      annotations.containsKey(NotMatches.class)
          ? UTemplater.getValue(annotations.getInstance(NotMatches.class))
          : null;
  final Predicate<Tree.Kind> allowedKinds =
      annotations.containsKey(OfKind.class)
          ? Predicates.<Tree.Kind>in(Arrays.asList(annotations.getInstance(OfKind.class).value()))
          : Predicates.<Tree.Kind>alwaysTrue();
  class PlaceholderMatcher implements Serializable,Matcher<ExpressionTree> {

    @Override
    public boolean matches(ExpressionTree t,VisitorState state) {
      try {
        return (allowsIdentity || !(t instanceof PlaceholderParamIdent))
            && (matchesClass == null || matchesClass.newInstance().matches(t,state))
            && (notMatchesClass == null || !notMatchesClass.newInstance().matches(t,state))
            && allowedKinds.apply(t.getKind());
      } catch (InstantiationException | IllegalAccessException e) {
        throw new RuntimeException(e);
      }
    }
  }
  return new AutoValue_PlaceholderMethod(
      StringName.of(name),returnType,parameters,new PlaceholderMatcher(),ImmutableClassToInstanceMap.<Annotation,Annotation>copyOf(annotations));
}
项目:error-prone    文件:UnnecessarySetDefaultTest.java   
@Test
public void exhaustive() throws ReflectiveOperationException {
  Field f = ArbitraryInstances.class.getDeclaredField("DEFAULTS");
  f.setAccessible(true);
  ClassToInstanceMap<?> actual = (ClassToInstanceMap<?>) f.get(null);
  assertThat(UnnecessarySetDefault.DEFAULTS.keySet())
      .containsAnyIn(
          actual.keySet().stream().map(Class::getCanonicalName).collect(toImmutableList()));
}
项目:cloudata    文件:CloudataConnectorFactory.java   
@Override
public Connector create(final String connectorId,String> requiredConfig) {
    checkNotNull(requiredConfig,"requiredConfig is null");
    checkNotNull(optionalConfig,"optionalConfig is null");

    try {
        // // A plugin is not required to use Guice; it is just very convenient
        // Bootstrap app = new Bootstrap(new JsonModule(),new ExampleModule(connectorId));
        //
        // Injector injector = app.strictConfig().doNotInitializeLogging()
        // .setRequiredConfigurationProperties(requiredConfig)
        // .setOptionalConfigurationProperties(optionalConfig).initialize();

        ClassToInstanceMap<Object> services = ImmutableClassToInstanceMap.builder()

        .put(ConnectorMetadata.class,new CloudataConnectorMetadata(connectorId,store))

        .put(ConnectorSplitManager.class,new CloudataSplitManager(nodeManager,connectorId))

        .put(ConnectorRecordSetProvider.class,new CloudataConnectorRecordSetProvider())

        .put(ConnectorHandleResolver.class,new CloudataConnectorHandleResolver()).build();

        CloudataConnector connector = new CloudataConnector(store,services);
        connectors.put(connectorId,connector);
        return connector;
    } catch (Exception e) {
        throw Throwables.propagate(e);
    }
}
项目:immutables    文件:StaticEnvironment.java   
static <T extends Completable> T getInstance(Class<T> type,instance);
  }
  return instance;
}
项目:rigel    文件:FieldSet.java   
@Override
public void storeValue(Map<DataKey<?>,? super Object> map,ClassToInstanceMap<FieldDataSource<?>> context) {
    R rawValue = field.getValue(context);
    if (eagerTransform) {
        map.put(this,formatRawValue(rawValue));
    } else {
        map.put(this,rawValue);
    }
}
项目:rigel    文件:ContentItemFactory.java   
public <T extends ContentItem> ImmutableList<T> fromResponse(QueryResponse response,ContentItem.Schema<T> forcedSchema,FieldSet... additionalFields) {
    ClassToInstanceMap<FieldDataSource<?>> context = MutableClassToInstanceMap.create();
    context.put(QueryResponseDataSource.class,new QueryResponseDataSource(response));

    Builder<T> builder = ImmutableList.builder();
    for(SolrDocument doc : response.getResults()) {
        context.put(SolrDocDataSource.class,new SolrDocDataSource(doc));
        context.put(SchemaDataSource.class,new SchemaDataSource(forcedSchema));
        builder.add(buildItem(forcedSchema,context,additionalFields));
    }
    return builder.build();
}
项目:rigel    文件:ContentItemFactory.java   
public <T extends ContentItem> ImmutableList<T> fromDocumentList(SolrDocumentList list,FieldSet... additionalFields) {
    ClassToInstanceMap<FieldDataSource<?>> context = MutableClassToInstanceMap.create();
    Builder<T> builder = ImmutableList.builder();
    for(SolrDocument doc : list) {
        context.put(SolrDocDataSource.class,additionalFields));
    }
    return builder.build();
}
项目:rigel    文件:ContentItemFactory.java   
public ImmutableList<ContentItem> fromResponse(QueryResponse response,new QueryResponseDataSource(response));

    Builder<ContentItem> builder = ImmutableList.builder();
    for(SolrDocument doc : response.getResults()) {
        ContentItem.Schema<?> schema = getSchemaForDocument(doc);
        context.put(SchemaDataSource.class,new SchemaDataSource(schema));
        context.put(SolrDocDataSource.class,new SolrDocDataSource(doc));
        builder.add(buildItem(schema,additionalFields));
    }
    return builder.build();
}
项目:rigel    文件:ContentItemFactory.java   
public ImmutableList<ContentItem> fromDocumentList(SolrDocumentList list,FieldSet... additionalFields) {
    ClassToInstanceMap<FieldDataSource<?>> context = MutableClassToInstanceMap.create();
    Builder<ContentItem> builder = ImmutableList.builder();
    for(SolrDocument doc : list) {
        ContentItem.Schema<?> schema = getSchemaForDocument(doc);
        context.put(SchemaDataSource.class,additionalFields));
    }
    return builder.build();
}
项目:rigel    文件:HighlightField.java   
@Override
public String getValue(ClassToInstanceMap<FieldDataSource<?>> context) {
    List<String> highlights = getHighlights(context);
    if (highlights == null || highlights.size() == 0) {
        return null;
    }
    return highlights.get(0);
}
项目:guava-mock    文件:ArbitraryInstancesTest.java   
public void testGet_collections() {
  assertEquals(ImmutableSet.of().iterator(),ArbitraryInstances.get(Iterator.class));
  assertFalse(ArbitraryInstances.get(PeekingIterator.class).hasNext());
  assertFalse(ArbitraryInstances.get(ListIterator.class).hasNext());
  assertEquals(ImmutableSet.of(),ArbitraryInstances.get(Iterable.class));
  assertEquals(ImmutableSet.of(),ArbitraryInstances.get(Set.class));
  assertEquals(ImmutableSet.of(),ArbitraryInstances.get(ImmutableSet.class));
  assertEquals(ImmutableSortedSet.of(),ArbitraryInstances.get(SortedSet.class));
  assertEquals(ImmutableSortedSet.of(),ArbitraryInstances.get(ImmutableSortedSet.class));
  assertEquals(ImmutableList.of(),ArbitraryInstances.get(Collection.class));
  assertEquals(ImmutableList.of(),ArbitraryInstances.get(ImmutableCollection.class));
  assertEquals(ImmutableList.of(),ArbitraryInstances.get(List.class));
  assertEquals(ImmutableList.of(),ArbitraryInstances.get(ImmutableList.class));
  assertEquals(ImmutableMap.of(),ArbitraryInstances.get(Map.class));
  assertEquals(ImmutableMap.of(),ArbitraryInstances.get(ImmutableMap.class));
  assertEquals(ImmutableSortedMap.of(),ArbitraryInstances.get(SortedMap.class));
  assertEquals(ImmutableSortedMap.of(),ArbitraryInstances.get(ImmutableSortedMap.class));
  assertEquals(ImmutableMultiset.of(),ArbitraryInstances.get(Multiset.class));
  assertEquals(ImmutableMultiset.of(),ArbitraryInstances.get(ImmutableMultiset.class));
  assertTrue(ArbitraryInstances.get(SortedMultiset.class).isEmpty());
  assertEquals(ImmutableMultimap.of(),ArbitraryInstances.get(Multimap.class));
  assertEquals(ImmutableMultimap.of(),ArbitraryInstances.get(ImmutableMultimap.class));
  assertTrue(ArbitraryInstances.get(SortedSetMultimap.class).isEmpty());
  assertEquals(ImmutableTable.of(),ArbitraryInstances.get(Table.class));
  assertEquals(ImmutableTable.of(),ArbitraryInstances.get(ImmutableTable.class));
  assertTrue(ArbitraryInstances.get(RowSortedTable.class).isEmpty());
  assertEquals(ImmutableBiMap.of(),ArbitraryInstances.get(BiMap.class));
  assertEquals(ImmutableBiMap.of(),ArbitraryInstances.get(ImmutableBiMap.class));
  assertTrue(ArbitraryInstances.get(ImmutableClassToInstanceMap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(ClassToInstanceMap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(ListMultimap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(ImmutableListMultimap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(SetMultimap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(ImmutableSetMultimap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(MapDifference.class).areEqual());
  assertTrue(ArbitraryInstances.get(SortedMapDifference.class).areEqual());
  assertEquals(Range.all(),ArbitraryInstances.get(Range.class));
  assertTrue(ArbitraryInstances.get(NavigableSet.class).isEmpty());
  assertTrue(ArbitraryInstances.get(NavigableMap.class).isEmpty());
  assertTrue(ArbitraryInstances.get(LinkedList.class).isEmpty());
  assertTrue(ArbitraryInstances.get(Deque.class).isEmpty());
  assertTrue(ArbitraryInstances.get(Queue.class).isEmpty());
  assertTrue(ArbitraryInstances.get(PriorityQueue.class).isEmpty());
  assertTrue(ArbitraryInstances.get(BitSet.class).isEmpty());
  assertTrue(ArbitraryInstances.get(TreeSet.class).isEmpty());
  assertTrue(ArbitraryInstances.get(TreeMap.class).isEmpty());
  assertFreshInstanceReturned(
      LinkedList.class,Deque.class,Queue.class,PriorityQueue.class,BitSet.class,TreeSet.class,TreeMap.class);
}
项目:googles-monorepo-demo    文件:ArbitraryInstancesTest.java   
public void testGet_collections() {
  assertEquals(ImmutableSet.of().iterator(),TreeMap.class);
}
项目:hashsdn-controller    文件:BrokerImpl.java   
public BrokerImpl(final DOMRpcRouter router,final ClassToInstanceMap<BrokerService> services) {
    this(router,router,services);
}
项目:hashsdn-controller    文件:BrokerImpl.java   
public BrokerImpl(final DOMRpcService rpcService,final DOMRpcProviderService rpcProvider,final ClassToInstanceMap<BrokerService> services) {
    this.rpcService = Preconditions.checkNotNull(rpcService,"DOMRpcService must not be null");
    this.rpcProvider = Preconditions.checkNotNull(rpcProvider,"DOMRpcProviderService must not be null");
    this.services = ImmutableClassToInstanceMap.copyOf(services);
}
项目:hashsdn-controller    文件:SimpleDOMMountPoint.java   
public static final SimpleDOMMountPoint create(final YangInstanceIdentifier identifier,final ClassToInstanceMap<DOMService> services,final SchemaContext ctx) {
    return new SimpleDOMMountPoint(identifier,services,ctx);
}
项目:hashsdn-controller    文件:SimpleDOMMountPoint.java   
private SimpleDOMMountPoint(final YangInstanceIdentifier identifier,final SchemaContext ctx) {
    this.identifier = identifier;
    this.services = ImmutableClassToInstanceMap.copyOf(services);
    this.schemaContext = ctx;
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public static ConsumerContext createConsumerContext(BindingAwareConsumer consumer,ClassToInstanceMap<BindingAwareService> serviceProvider) {
    checkNotNull(consumer,"Consumer should not be null");
    checkNotNull(serviceProvider,"Service map should not be null");
    return new SingleConsumerContextImpl(serviceProvider);
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public static ProviderContext createProviderContext(BindingAwareProvider provider,ClassToInstanceMap<BindingAwareService> serviceProvider) {
    checkNotNull(provider,"Provider should not be null");
    checkNotNull(serviceProvider,"Service map should not be null");
    return new SingleProviderContextImpl(serviceProvider);
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public static ConsumerContext createConsumerContextAndInitialize(BindingAwareConsumer consumer,ClassToInstanceMap<BindingAwareService> serviceProvider) {
    ConsumerContext context = createConsumerContext(consumer,serviceProvider);
    consumer.onSessionInitialized(context);
    return context;
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public static ProviderContext createProviderContextAndInitialize(BindingAwareProvider provider,ClassToInstanceMap<BindingAwareService> serviceProvider) {
    ProviderContext context = createProviderContext(provider,serviceProvider);
    provider.onSessionInitiated(context);
    return context;
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public SingleConsumerContextImpl(ClassToInstanceMap<BindingAwareService> serviceProvider) {
    this.alreadyRetrievedServices = MutableClassToInstanceMap.create();
    this.serviceProvider = serviceProvider;
}
项目:hashsdn-controller    文件:BindingContextUtils.java   
public SingleProviderContextImpl(ClassToInstanceMap<BindingAwareService> serviceProvider) {
    super(serviceProvider);
}
项目:hashsdn-controller    文件:BindingDOMAdapterBuilder.java   
@Override
protected final T createInstance(final ClassToInstanceMap<DOMService> delegates) {
    Preconditions.checkState(codec != null);
    return createInstance(codec,delegates);
}
项目:hashsdn-controller    文件:BindingDOMDataBrokerAdapter.java   
@Override
protected DataBroker createInstance(final BindingToNormalizedNodeCodec codec,final ClassToInstanceMap<DOMService> delegates) {
    final DOMDataBroker domDataBroker = delegates.getInstance(DOMDataBroker.class);
    return new BindingDOMDataBrokerAdapter(domDataBroker,codec);
}
项目:hashsdn-controller    文件:BindingDOMRpcServiceAdapter.java   
@Override
protected RpcConsumerRegistry createInstance(final BindingToNormalizedNodeCodec codec,final ClassToInstanceMap<DOMService> delegates) {
    final DOMRpcService domRpc  = delegates.getInstance(DOMRpcService.class);
    return new BindingDOMRpcServiceAdapter(domRpc,codec);
}
项目:hashsdn-controller    文件:BindingDOMNotificationPublishServiceAdapter.java   
@Override
protected NotificationPublishService createInstance(final BindingToNormalizedNodeCodec codec,final ClassToInstanceMap<DOMService> delegates) {
    final DOMNotificationPublishService domPublish = delegates.getInstance(DOMNotificationPublishService.class);
    return new BindingDOMNotificationPublishServiceAdapter(codec,domPublish);
}
项目:hashsdn-controller    文件:BindingDOMNotificationServiceAdapter.java   
@Override
protected NotificationService createInstance(final BindingToNormalizedNodeCodec codec,final ClassToInstanceMap<DOMService> delegates) {
    final DOMNotificationService domNotification = delegates.getInstance(DOMNotificationService.class);
    return new BindingDOMNotificationServiceAdapter(codec.getCodecRegistry(),domNotification);
}
项目:hashsdn-controller    文件:DomBrokerImplModule.java   
@Override
public java.lang.AutoCloseable createInstance() {
    // The services are provided via blueprint so retrieve then from the OSGi service registry for
    // backwards compatibility.

    final List<AutoCloseable> closeables = new ArrayList<>();
    DOMNotificationService domNotificationService = newTracker(
            DOMNotificationService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMNotificationPublishService domNotificationPublishService = newTracker(
            DOMNotificationPublishService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMRpcService domRpcService = newTracker(
            DOMRpcService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMRpcProviderService domRpcProvider = newTracker(
            DOMRpcProviderService.class,closeables).waitForService(WaitingServiceTracker.FIVE_MINUTES);

    DOMMountPointService mountService = newTracker(DOMMountPointService.class,closeables).
            waitForService(WaitingServiceTracker.FIVE_MINUTES);

    SchemaService globalSchemaService = newTracker(SchemaService.class,closeables).
            waitForService(WaitingServiceTracker.FIVE_MINUTES);

    final DOMDataBroker dataBroker = getAsyncDataBrokerDependency();

    final ClassToInstanceMap<BrokerService> services = MutableClassToInstanceMap.create();

    services.putInstance(DOMNotificationService.class,domNotificationService);
    services.putInstance(DOMNotificationPublishService.class,domNotificationPublishService);

    final SchemaService schemaService = getSchemaServiceImpl(globalSchemaService);
    services.putInstance(SchemaService.class,schemaService);

    services.putInstance(DOMDataBroker.class,dataBroker);

    services.putInstance(DOMRpcService.class,domRpcService);
    services.putInstance(DOMRpcProviderService.class,domRpcProvider);

    services.putInstance(DOMMountPointService.class,mountService);

    BrokerImpl broker = new BrokerImpl(domRpcService,domRpcProvider,services);
    broker.setDeactivator(() -> {
        for (AutoCloseable ac : closeables) {
            try {
                ac.close();
            } catch (Exception e) {
                LOG.warn("Exception while closing {}",ac,e);
            }
        }
    });

    return broker;
}
项目:FinanceAnalytics    文件:DiscountingMulticurveBundleFnTest.java   
@BeforeClass
public void init() throws IOException {
  //builds graph,initializing mocks

  ClassToInstanceMap<Object> mocks = MockUtils.mocks(MOCK_CLASSES);

  initConfigSource(mocks.getInstance(ConfigSource.class));
  initConventionSource(mocks.getInstance(ConventionSource.class));
  initSecuritySource(mocks.getInstance(SecuritySource.class));
  initRegionSource(mocks.getInstance(RegionSource.class));

  mocks.putInstance(RootFinderConfiguration.class,ROOT_FINDER_CONFIG);
  mocks.putInstance(HolidaySource.class,new WeekendHolidaySource());

  mocks.putInstance(LegalEntitySource.class,mock(LegalEntitySource.class));
  mocks.putInstance(ConventionBundleSource.class,mock(ConventionBundleSource.class));
  ComponentMap components = ComponentMap.of(mocks);

  FunctionModelConfig config = config(
      arguments(
          function(DefaultDiscountingMulticurveBundleFn.class,argument("impliedCurveNames",StringSet.of("Implied Deposit Curve KRW"))),function(DefaultCurveNodeConverterFn.class,argument("timeSeriesDuration",RetrievalPeriod.of(Period.ofDays(1))))),implementations(CurveDefinitionFn.class,DefaultCurveDefinitionFn.class,CurveSpecificationFn.class,DefaultCurveSpecificationFn.class,CurveSpecificationMarketDataFn.class,DefaultCurveSpecificationMarketDataFn.class,CurveNodeConverterFn.class,DefaultCurveNodeConverterFn.class,FXMatrixFn.class,DefaultFXMatrixFn.class,DiscountingMulticurveBundleFn.class,DefaultDiscountingMulticurveBundleFn.class,DiscountingMulticurveBundleResolverFn.class,DefaultDiscountingMulticurveBundleResolverFn.class,MarketDataFn.class,DefaultMarketDataFn.class));

  _multicurveBundleFn = FunctionModel.build(DiscountingMulticurveBundleResolverFn.class,config,components);

  ZonedDateTime valuationDate = ZonedDateTime.of(2014,1,10,11,ZoneId.of("America/Chicago"));
  MarketDataBundle marketDataBundle =
      MarketDataResourcesLoader.getPreloadedBundle(
          "/regression/curve_testing/usdMarketQuotes.properties","Ticker");

  _environment = new SimpleEnvironment(valuationDate,marketDataBundle);

  VersionCorrectionProvider vcProvider = new TestVersionCorrectionProvider();

  ServiceContext serviceContext = ServiceContext.of(mocks).with(VersionCorrectionProvider.class,vcProvider);
  ThreadLocalServiceContext.init(serviceContext);

  _usdDiscountingCCC = createUSDCurveConstructionConfig();
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


com.google.gson.internal.bind.ArrayTypeAdapter的实例源码
com.google.gson.JsonSyntaxException的实例源码
com.google.gson.JsonDeserializer的实例源码
com.google.gson.internal.ConstructorConstructor的实例源码
com.google.gson.JsonPrimitive的实例源码
com.google.gson.LongSerializationPolicy的实例源码
com.google.gson.internal.GsonInternalAccess的实例源码
com.google.gson.JsonIOException的实例源码
com.google.gson.internal.StringMap的实例源码
com.google.gson.JsonObject的实例源码
com.google.gson.internal.bind.TimeTypeAdapter的实例源码
com.google.gson.FieldAttributes的实例源码
com.google.gson.internal.bind.TreeTypeAdapter的实例源码
com.google.gson.internal.LinkedHashTreeMap的实例源码
com.google.gson.TypeAdapterFactory的实例源码
com.google.gson.JsonSerializer的实例源码
com.google.gson.FieldNamingPolicy的实例源码
com.google.gson.JsonElement的实例源码
com.google.gson.internal.JsonReaderInternalAccess的实例源码
com.google.gson.TypeAdapter的实例源码