微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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();
}

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