org.apache.camel.spi.MessageHistoryFactory的实例源码

项目：Camel    文件：CamelInternalProcessor.java   

public MessageHistoryAdvice(MessageHistoryFactory factory,ProcessorDeFinition<?> deFinition) {
    this.factory = factory;
    this.deFinition = deFinition;
    this.routeId = ProcessorDeFinitionHelper.getRouteId(deFinition);
}

项目：Camel    文件：DefaultCamelContext.java   

public MessageHistoryFactory getMessageHistoryFactory() {
    return messageHistoryFactory;
}

项目：Camel    文件：DefaultCamelContext.java   

public void setMessageHistoryFactory(MessageHistoryFactory messageHistoryFactory) {
    this.messageHistoryFactory = messageHistoryFactory;
}

项目：Camel    文件：AbstractCamelContextfactorybean.java   

private void setupCustomServices() {
    ModelJAXBContextFactory modelJAXBContextFactory = getBeanForType(ModelJAXBContextFactory.class);
    if (modelJAXBContextFactory != null) {
        LOG.info("Using custom ModelJAXBContextFactory: {}",modelJAXBContextFactory);
        getContext().setModelJAXBContextFactory(modelJAXBContextFactory);
    }
    ClassResolver classResolver = getBeanForType(ClassResolver.class);
    if (classResolver != null) {
        LOG.info("Using custom ClassResolver: {}",classResolver);
        getContext().setClassResolver(classResolver);
    }
    FactoryFinderResolver factoryFinderResolver = getBeanForType(FactoryFinderResolver.class);
    if (factoryFinderResolver != null) {
        LOG.info("Using custom FactoryFinderResolver: {}",factoryFinderResolver);
        getContext().setFactoryFinderResolver(factoryFinderResolver);
    }
    ExecutorServiceManager executorServiceStrategy = getBeanForType(ExecutorServiceManager.class);
    if (executorServiceStrategy != null) {
        LOG.info("Using custom ExecutorServiceStrategy: {}",executorServiceStrategy);
        getContext().setExecutorServiceManager(executorServiceStrategy);
    }
    ThreadPoolFactory threadPoolFactory = getBeanForType(ThreadPoolFactory.class);
    if (threadPoolFactory != null) {
        LOG.info("Using custom ThreadPoolFactory: {}",threadPoolFactory);
        getContext().getExecutorServiceManager().setThreadPoolFactory(threadPoolFactory);
    }
    ProcessorFactory processorFactory = getBeanForType(ProcessorFactory.class);
    if (processorFactory != null) {
        LOG.info("Using custom ProcessorFactory: {}",processorFactory);
        getContext().setProcessorFactory(processorFactory);
    }
    Debugger debugger = getBeanForType(Debugger.class);
    if (debugger != null) {
        LOG.info("Using custom Debugger: {}",debugger);
        getContext().setDebugger(debugger);
    }
    UuidGenerator uuidGenerator = getBeanForType(UuidGenerator.class);
    if (uuidGenerator != null) {
        LOG.info("Using custom UuidGenerator: {}",uuidGenerator);
        getContext().setUuidGenerator(uuidGenerator);
    }
    NodeIdFactory nodeIdFactory = getBeanForType(NodeIdFactory.class);
    if (nodeIdFactory != null) {
        LOG.info("Using custom NodeIdFactory: {}",nodeIdFactory);
        getContext().setNodeIdFactory(nodeIdFactory);
    }
    StreamCachingStrategy streamCachingStrategy = getBeanForType(StreamCachingStrategy.class);
    if (streamCachingStrategy != null) {
        LOG.info("Using custom StreamCachingStrategy: {}",streamCachingStrategy);
        getContext().setStreamCachingStrategy(streamCachingStrategy);
    }
    MessageHistoryFactory messageHistoryFactory = getBeanForType(MessageHistoryFactory.class);
    if (messageHistoryFactory != null) {
        LOG.info("Using custom MessageHistoryFactory: {}",messageHistoryFactory);
        getContext().setMessageHistoryFactory(messageHistoryFactory);
    }
}

项目：microservice-bundle    文件：ManagedCamelContext.java   

@Override
public MessageHistoryFactory getMessageHistoryFactory() {
  return context.getMessageHistoryFactory();
}

项目：microservice-bundle    文件：ManagedCamelContext.java   

@Override
public void setMessageHistoryFactory(MessageHistoryFactory messageHistoryFactory) {
  context.setMessageHistoryFactory(messageHistoryFactory);
}

项目：dropwizard-camel    文件：ManagedCamelContext.java   

@Override
public MessageHistoryFactory getMessageHistoryFactory() {
    return context.getMessageHistoryFactory();
}

项目：dropwizard-camel    文件：ManagedCamelContext.java   

@Override
public void setMessageHistoryFactory(MessageHistoryFactory messageHistoryFactory) {
    context.setMessageHistoryFactory(messageHistoryFactory);
}

项目：Camel    文件：CamelContext.java   

/**
 * Gets the current {@link org.apache.camel.spi.MessageHistoryFactory}
 *
 * @return the factory
 */
MessageHistoryFactory getMessageHistoryFactory();

项目：Camel    文件：CamelContext.java   

/**
 * Sets a custom {@link org.apache.camel.spi.MessageHistoryFactory}
 *
 * @param messageHistoryFactory the custom factory
 */
void setMessageHistoryFactory(MessageHistoryFactory messageHistoryFactory);