本文整理汇总了Java中org.uberfire.io.IOService类的典型用法代码示例。如果您正苦于以下问题：Java IOService类的具体用法？Java IOService怎么用？Java IOService使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IOService类属于org.uberfire.io包，在下文中一共展示了IOService类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: AppSetup
import org.uberfire.io.IOService; //导入依赖的package包/类
@Inject
public AppSetup(@Named("ioStrategy") final IOService ioService,
final RepositoryService repositoryService,
final OrganizationalUnitService organizationalUnitService,
final KieProjectService projectService,
final ConfigurationService configurationService,
final ConfigurationFactory configurationFactory,
final Event<ApplicationStarted> applicationStartedEvent) {
super(ioService,
repositoryService,
organizationalUnitService,
projectService,
configurationService,
configurationFactory);
this.applicationStartedEvent = applicationStartedEvent;
}
开发者ID:kiegroup，项目名称:optaplanner-wb，代码行数:18，代码来源:AppSetup.java
示例2: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder()
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
ioService = new IOServiceIndexedImpl(config.getIndexEngine(),
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class);
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:17，代码来源:BaseIndexTest.java
示例3: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
@Override
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder()
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
ioService = new IOServiceIndexedImpl(config.getIndexEngine(),
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class);
IndexersFactory.addIndexer(new MockIndexer());
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:19，代码来源:LuceneFullTextSearchIndexTest.java
示例4: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
@Override
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder()
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
metaIndexEngine = spy(config.getIndexEngine());
ioService = new IOServiceIndexedImpl(metaIndexEngine,
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class) {
@Override
protected void setupWatchService(final FileSystem fs) {
//No WatchService for this test
}
};
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:24，代码来源:BatchIndexConcurrencyTest.java
示例5: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder("elastic")
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
ioService = new IOServiceIndexedImpl(config.getIndexEngine(),
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class);
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:17，代码来源:BaseIndexTest.java
示例6: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
@Override
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder("elastic")
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
ioService = new IOServiceIndexedImpl(config.getIndexEngine(),
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class);
IndexersFactory.addIndexer(new MockIndexer());
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:19，代码来源:ElasticFullTextSearchIndexTest.java
示例7: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder("elastic")
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.usingAnalyzers(new HashMap<String, Analyzer>() {{
put("file",
new FilenameAnalyzer());
}})
.build();
ioService = new IOServiceIndexedImpl(config.getIndexEngine(),
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class);
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:21，代码来源:ComplexFieldsTest.java
示例8: ioService
import org.uberfire.io.IOService; //导入依赖的package包/类
@Override
protected IOService ioService() {
if (ioService == null) {
config = new MetadataConfigBuilder("elastic")
.withInMemoryMetaModelStore()
.useDirectoryBasedIndex()
.useInMemoryDirectory()
.build();
metaIndexEngine = spy(config.getIndexEngine());
ioService = new IOServiceIndexedImpl(metaIndexEngine,
Executors.newCachedThreadPool(new DescriptiveThreadFactory()),
DublinCoreView.class,
VersionAttributeView.class) {
@Override
protected void setupWatchService(final FileSystem fs) {
//No WatchService for this test
}
};
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:24，代码来源:BatchIndexConcurrencyTest.java
示例9: CopyServiceImpl
import org.uberfire.io.IOService; //导入依赖的package包/类
@Inject
public CopyServiceImpl(@Named("ioStrategy") IOService ioService,
User identity,
SessionInfo sessionInfo,
Instance<CopyHelper> helpers,
Event<ResourceCopiedEvent> resourceCopiedEvent,
Instance<CopyRestrictor> copyRestrictorBeans,
PathNamingService pathNamingService) {
this.ioService = ioService;
this.identity = identity;
this.sessionInfo = sessionInfo;
this.helpers = helpers;
this.resourceCopiedEvent = resourceCopiedEvent;
this.copyRestrictorBeans = copyRestrictorBeans;
this.pathNamingService = pathNamingService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:17，代码来源:CopyServiceImpl.java
示例10: SocialTimelineCacheClusterPersistence
import org.uberfire.io.IOService; //导入依赖的package包/类
public SocialTimelineCacheClusterPersistence(final Gson gson,
final Type gsonCollectionType,
final IOService ioService,
final SocialEventTypeRepositoryAPI socialEventTypeRepository,
final SocialUserPersistenceAPI socialUserPersistenceAPI,
final SocialClusterMessaging socialClusterMessaging,
final SocialUserServicesExtendedBackEndImpl userServicesBackend,
final FileSystem fileSystem,
final SocialSecurityConstraintsManager socialSecurityConstraintsManager) {
this.gson = gson;
this.gsonCollectionType = gsonCollectionType;
this.ioService = ioService;
this.socialEventTypeRepository = socialEventTypeRepository;
this.socialUserPersistenceAPI = socialUserPersistenceAPI;
this.socialClusterMessaging = socialClusterMessaging;
this.userServicesBackend = userServicesBackend;
this.fileSystem = fileSystem;
this.socialSecurityConstraintsManager = socialSecurityConstraintsManager;
PriorityDisposableRegistry.register(this);
}
开发者ID:kiegroup，项目名称:appformer，代码行数:21，代码来源:SocialTimelineCacheClusterPersistence.java
示例11: SocialTimelineCacheInstancePersistence
import org.uberfire.io.IOService; //导入依赖的package包/类
public SocialTimelineCacheInstancePersistence(final Gson gson,
final Type gsonCollectionType,
final IOService ioService,
final SocialEventTypeRepositoryAPI socialEventTypeRepository,
final SocialUserPersistenceAPI socialUserService,
final SocialUserServicesExtendedBackEndImpl userServicesBackend,
final FileSystem fileSystem,
final SocialSecurityConstraintsManager socialSecurityConstraintsManager) {
this.gsonCollectionType = gsonCollectionType;
this.gson = gson;
this.ioService = ioService;
this.socialEventTypeRepository = socialEventTypeRepository;
this.socialUserPersistenceAPI = socialUserService;
this.userServicesBackend = userServicesBackend;
this.fileSystem = fileSystem;
this.socialSecurityConstraintsManager = socialSecurityConstraintsManager;
PriorityDisposableRegistry.register(this);
}
开发者ID:kiegroup，项目名称:appformer，代码行数:19，代码来源:SocialTimelineCacheInstancePersistence.java
示例12: setupSocialUserPersistenceAPI
import org.uberfire.io.IOService; //导入依赖的package包/类
void setupSocialUserPersistenceAPI(IOService _ioService,
SocialUserServicesExtendedBackEndImpl userServicesBackend) {
if (!clusterService.isAppFormerClustered()) {
socialUserPersistenceAPI = new SocialUserInstancePersistence(userServicesBackend,
userServices,
_ioService,
gson);
} else {
socialUserPersistenceAPI = new SocialUserClusterPersistence(userServicesBackend,
userServices,
_ioService,
gson,
socialUserClusterMessaging);
socialUserClusterMessaging.setup(clusterService, socialUserPersistenceAPI);
}
socialUserPersistenceAPI.setup();
}
开发者ID:kiegroup，项目名称:appformer，代码行数:18，代码来源:SocialUserPersistenceProducer.java
示例13: setupSocialTimelinePersistenceAPI
import org.uberfire.io.IOService; //导入依赖的package包/类
void setupSocialTimelinePersistenceAPI(IOService _ioService,
FileSystem _fileSystem,
SocialUserServicesExtendedBackEndImpl userServicesBackend) {
if (!clusterService.isAppFormerClustered()) {
socialTimelinePersistenceAPI = new SocialTimelineCacheInstancePersistence(gson,
gsonCollectionType,
_ioService,
socialEventTypeRepository,
socialUserPersistenceAPI,
userServicesBackend,
_fileSystem,
socialSecurityConstraintsManager);
} else {
socialTimelinePersistenceAPI = new SocialTimelineCacheClusterPersistence(gson,
gsonCollectionType,
_ioService,
socialEventTypeRepository,
socialUserPersistenceAPI,
socialClusterMessaging,
userServicesBackend,
_fileSystem,
socialSecurityConstraintsManager);
socialClusterMessaging.setup(clusterService, socialTimelinePersistenceAPI, socialUserPersistenceAPI);
}
socialTimelinePersistenceAPI.setup();
}
开发者ID:kiegroup，项目名称:appformer，代码行数:27，代码来源:SocialTimelinePersistenceProducer.java
示例14: createAndDestroyFSShouldRegisterUnregisterOnPriorityDisposableRegistry
import org.uberfire.io.IOService; //导入依赖的package包/类
@Test
public void createAndDestroyFSShouldRegisterUnregisterOnPriorityDisposableRegistry() throws Exception {
when(bm.getBeans("configIO")).thenReturn(configIOBeans);
when(bm.getReference(eq(ioServiceBean),
eq(IOService.class),
any(CreationalContext.class)))
.thenReturn(ioServiceMock);
when(ioServiceMock.newFileSystem(any(URI.class),
any(Map.class)))
.thenReturn(fs);
final Bean fileSystemBean = producer.createFileSystemBean(bm,
mock(InjectionTarget.class));
assertNull(PriorityDisposableRegistry.get("systemFS"));
fileSystemBean.create(mock(CreationalContext.class));
assertNotNull(PriorityDisposableRegistry.get("systemFS"));
fileSystemBean.destroy(fs,
mock(CreationalContext.class));
assertNull(PriorityDisposableRegistry.get("systemFS"));
}
开发者ID:kiegroup，项目名称:appformer，代码行数:27，代码来源:SystemConfigProducerTest.java
示例15: DataSetDefRegistryCDI
import org.uberfire.io.IOService; //导入依赖的package包/类
@Inject
public DataSetDefRegistryCDI(@Config("10485760" /* 10 Mb */) int maxCsvLength,
@Named("ioStrategy") IOService ioService,
DataSetProviderRegistryCDI dataSetProviderRegistry,
SchedulerCDI scheduler,
ExceptionManager exceptionManager,
Event<DataSetDefModifiedEvent> dataSetDefModifiedEvent,
Event<DataSetDefRegisteredEvent> dataSetDefRegisteredEvent,
Event<DataSetDefRemovedEvent> dataSetDefRemovedEvent,
Event<DataSetStaleEvent> dataSetStaleEvent) {
super(dataSetProviderRegistry,
scheduler);
this.uuidGenerator = DataSetCore.get().getUuidGenerator();
this.maxCsvLength = maxCsvLength;
this.ioService = ioService;
this.exceptionManager = exceptionManager;
this.dataSetDefModifiedEvent = dataSetDefModifiedEvent;
this.dataSetDefRegisteredEvent = dataSetDefRegisteredEvent;
this.dataSetDefRemovedEvent = dataSetDefRemovedEvent;
this.dataSetStaleEvent = dataSetStaleEvent;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:23，代码来源:DataSetDefRegistryCDI.java
示例16: getIOService
import org.uberfire.io.IOService; //导入依赖的package包/类
public IOService getIOService() throws Exception {
if (ioService == null) {
ioService = mock(IOService.class);
FileSystem fileSystem = mock(FileSystem.class);
Iterable iterable = mock(Iterable.class);
Iterator iterator = mock(Iterator.class);
Path path = mock(Path.class);
when(ioService.newFileSystem(any(URI.class), any(Map.class))).thenReturn(fileSystem);
when(ioService.getFileSystem(any(URI.class))).thenReturn(fileSystem);
when(fileSystem.getRootDirectories()).thenReturn(iterable);
when(fileSystem.supportedFileAttributeViews()).thenReturn(new HashSet<String>());
when(iterable.iterator()).thenReturn(iterator);
when(iterator.next()).thenReturn(path);
when(path.resolve(anyString())).thenReturn(path);
when(path.resolve(any(Path.class))).thenReturn(path);
when(path.toUri()).thenReturn(new URI("uri"));
when(path.getFileName()).thenReturn(path);
when(path.getFileSystem()).thenReturn(fileSystem);
}
return ioService;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:25，代码来源:BaseCDITest.java
示例17: MetadataCreator
import org.uberfire.io.IOService; //导入依赖的package包/类
public MetadataCreator(Path path,
IOService configIOService,
SessionInfo sessionInfo,
DublinCoreView dublinCoreView,
DiscussionView discussionView,
OtherMetaView otherMetaView,
VersionAttributeView versionAttributeView,
GeneratedAttributesView generatedAttributesView) {
this.path = checkNotNull("path",
path);
this.configIOService = checkNotNull("configIOService",
configIOService);
this.sessionInfo = checkNotNull("sessionInfo",
sessionInfo);
this.dublinCoreView = checkNotNull("dublinCoreView",
dublinCoreView);
this.discussView = checkNotNull("discussionView",
discussionView);
this.otherMetaView = checkNotNull("otherMetaView",
otherMetaView);
this.versionAttributeView = checkNotNull("versionAttributeView",
versionAttributeView);
this.generatedAttributesView = checkNotNull("generatedAttributesView",
generatedAttributesView);
}
开发者ID:kiegroup，项目名称:appformer，代码行数:26，代码来源:MetadataCreator.java
示例18: RepositoryStructureServiceImpl
import org.uberfire.io.IOService; //导入依赖的package包/类
@Inject
public RepositoryStructureServiceImpl(final @Named("ioStrategy") IOService ioService,
final POMService pomService,
final ProjectService<? extends Project> projectService,
final GuvnorM2Repository m2service,
final CommentedOptionFactory optionsFactory,
final ProjectRepositoryResolver repositoryResolver,
final RepositoryStructureModelLoader modelLoader,
final ManagedStatusUpdater managedStatusUpdater) {
this.ioService = ioService;
this.pomService = pomService;
this.projectService = projectService;
this.m2service = m2service;
this.optionsFactory = optionsFactory;
this.repositoryResolver = repositoryResolver;
this.modelLoader = modelLoader;
this.managedStatusUpdater = managedStatusUpdater;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:19，代码来源:RepositoryStructureServiceImpl.java
示例19: ConfigurationServiceImpl
import org.uberfire.io.IOService; //导入依赖的package包/类
@Inject
public ConfigurationServiceImpl(final @Named("system") org.guvnor.structure.repositories.Repository systemRepository,
final ConfigGroupMarshaller marshaller,
final User identity,
final @Named("configIO") IOService ioService,
final @Repository Event<SystemRepositoryChangedEvent> repoChangedEvent,
final @OrgUnit Event<SystemRepositoryChangedEvent> orgUnitChangedEvent,
final Event<SystemRepositoryChangedEvent> changedEvent,
final @Named("systemFS") FileSystem fs) {
this.systemRepository = systemRepository;
this.marshaller = marshaller;
this.identity = identity;
this.ioService = ioService;
this.repoChangedEvent = repoChangedEvent;
this.orgUnitChangedEvent = orgUnitChangedEvent;
this.changedEvent = changedEvent;
this.fs = fs;
}
开发者ID:kiegroup，项目名称:appformer，代码行数:19，代码来源:ConfigurationServiceImpl.java
示例20: setUp
import org.uberfire.io.IOService; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
ioService = mock(IOService.class);
notIndexed = mock(IOService.class);
helper = new GitRepositoryFactoryHelper(ioService, notIndexed);
fileSystem = mock(FileSystem.class);
when(
ioService.newFileSystem(any(URI.class),
anyMap())
).thenReturn(
fileSystem
);
when(
notIndexed.newFileSystem(any(URI.class),
anyMap())
).thenThrow(new RuntimeException());
rootDirectories = new ArrayList<Path>();
when(fileSystem.getRootDirectories()).thenReturn(rootDirectories);
}
开发者ID:kiegroup，项目名称:appformer，代码行数:23，代码来源:GitRepositoryFactoryHelperTest.java
注：本文中的org.uberfire.io.IOService类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论