- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.uberfire.java.nio.file.WatchService.poll()
方法的一些代码示例,展示了WatchService.poll()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WatchService.poll()
方法的具体详情如下:
包路径:org.uberfire.java.nio.file.WatchService
类名称:WatchService
方法名:poll
暂无
代码示例来源:origin: org.uberfire/uberfire-nio2-model
@Override
public WatchKey register(WatchService watcher,
Kind<?>... events)
throws UnsupportedOperationException, IllegalArgumentException,
ClosedWatchServiceException, IOException, SecurityException {
return watcher.poll();
}
代码示例来源:origin: org.uberfire/uberfire-nio2-model
@Override
public WatchKey register(WatchService watcher,
Kind<?>[] events,
Modifier... modifiers)
throws UnsupportedOperationException, IllegalArgumentException,
ClosedWatchServiceException, IOException, SecurityException {
return watcher.poll();
}
代码示例来源:origin: kiegroup/appformer
@Override
public WatchKey register(WatchService watcher,
Kind<?>... events)
throws UnsupportedOperationException, IllegalArgumentException,
ClosedWatchServiceException, IOException, SecurityException {
return watcher.poll();
}
代码示例来源:origin: kiegroup/appformer
@Override
public WatchKey register(WatchService watcher,
Kind<?>[] events,
Modifier... modifiers)
throws UnsupportedOperationException, IllegalArgumentException,
ClosedWatchServiceException, IOException, SecurityException {
return watcher.poll();
}
代码示例来源:origin: org.uberfire/uberfire-nio2-jgit
false);
List<WatchEvent<?>> watchEvents = fsDora1.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora2.poll().pollEvents();
assertEquals(3,
watchEvents.size());
false);
watchEvents = fsDora2.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora2.poll().pollEvents();
assertEquals(2,
watchEvents.size());
watchEvents = fsDora1.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora1.poll().pollEvents();
assertEquals(2,
watchEvents.size());
代码示例来源:origin: kiegroup/appformer
false);
List<WatchEvent<?>> watchEvents = fsDora1.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora2.poll().pollEvents();
assertEquals(3,
watchEvents.size());
false);
watchEvents = fsDora2.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora2.poll().pollEvents();
assertEquals(2,
watchEvents.size());
watchEvents = fsDora1.poll().pollEvents();
assertEquals(3,
watchEvents.size());
watchEvents = fsDora1.poll().pollEvents();
assertEquals(2,
watchEvents.size());
代码示例来源:origin: org.uberfire/uberfire-io
@Test
public void simpleWatcherTest() {
final Path init = ioService.get(URI.create("git://amend-repo-test/dora1.txt"));
final WatchService ws = init.getFileSystem().newWatchService();
ioService.write(init,
"init!");
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
WatchEvent.Kind<?> kind = events.get(0).kind();
assertEquals(kind.name(),
StandardWatchEventKind.ENTRY_CREATE.name());
assertEquals(1,
events.size());
}
ioService.write(init,
"init 2!");
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
WatchEvent.Kind<?> kind = events.get(0).kind();
assertEquals(kind.name(),
StandardWatchEventKind.ENTRY_MODIFY.name());
assertEquals(1,
events.size());
}
}
}
代码示例来源:origin: kiegroup/appformer
@Test
public void simpleWatcherTest() {
final Path init = ioService.get(URI.create("git://amend-repo-test/dora1.txt"));
final WatchService ws = init.getFileSystem().newWatchService();
ioService.write(init,
"init!");
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
WatchEvent.Kind<?> kind = events.get(0).kind();
assertEquals(kind.name(),
StandardWatchEventKind.ENTRY_CREATE.name());
assertEquals(1,
events.size());
}
ioService.write(init,
"init 2!");
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
WatchEvent.Kind<?> kind = events.get(0).kind();
assertEquals(kind.name(),
StandardWatchEventKind.ENTRY_MODIFY.name());
assertEquals(1,
events.size());
}
}
}
代码示例来源:origin: org.uberfire/uberfire-io
"message1"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
代码示例来源:origin: org.uberfire/uberfire-io
@Test
public void deleteOnBatchEventShouldKeepUserInfo() {
final Path init = ioService.get(URI.create("git://amend-repo-test/file.txt"));
final WatchService ws = init.getFileSystem().newWatchService();
String user = "dora";
String message = "message";
ioService.write(init,
"init!",
new CommentedOption(user,
message));
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
}
ioService.startBatch(init.getFileSystem());
ioService.delete(init, new CommentedOption(user, message));
ioService.endBatch();
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
JGitWatchEvent event = (JGitWatchEvent) events.get(0);
WatchContext context = (WatchContext) event.context();
assertEquals(user, context.getUser());
}
}
代码示例来源:origin: kiegroup/appformer
@Test
public void deleteOnBatchEventShouldKeepUserInfo() {
final Path init = ioService.get(URI.create("git://amend-repo-test/file.txt"));
final WatchService ws = init.getFileSystem().newWatchService();
String user = "dora";
String message = "message";
ioService.write(init,
"init!",
new CommentedOption(user,
message));
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
}
ioService.startBatch(init.getFileSystem());
ioService.delete(init, new CommentedOption(user, message));
ioService.endBatch();
{
List<WatchEvent<?>> events = ws.poll().pollEvents();
JGitWatchEvent event = (JGitWatchEvent) events.get(0);
WatchContext context = (WatchContext) event.context();
assertEquals(user, context.getUser());
}
}
代码示例来源:origin: kiegroup/appformer
"message1"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
events.size());
List<WatchEvent<?>> events = ws.poll().pollEvents();
代码示例来源:origin: org.uberfire/uberfire-io
"message2"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
"message3"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
assertNotNull(ws.poll());
ioService.write(path,
"ooooo wdfs fg sdf!");
assertNull(ws.poll());
ioService.write(path2,
"ooooo222!");
assertNull(ws.poll());
ioService.write(path2,
" sdfsdg sdg ooooo222!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(4,
代码示例来源:origin: kiegroup/appformer
"message2"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
"message3"));
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(1,
assertNotNull(ws.poll());
ioService.write(path,
"ooooo wdfs fg sdf!");
assertNull(ws.poll());
ioService.write(path2,
"ooooo222!");
assertNull(ws.poll());
ioService.write(path2,
" sdfsdg sdg ooooo222!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(4,
代码示例来源:origin: kiegroup/appformer
ioService.write(f1,
"f1-u1!");
assertNull(ws.poll());
ioService.write(f2,
"f2-u1!");
assertNull(ws.poll());
ioService.write(f3,
"f3-u1!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(3,
ioService.write(f1,
"f1-u1!");
assertNull(ws.poll());
ioService.write(f2,
"f2-u2!");
assertNull(ws.poll());
ioService.write(f3,
"f3-u2!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(2,
代码示例来源:origin: org.uberfire/uberfire-io
ioService.write(f1,
"f1-u1!");
assertNull(ws.poll());
ioService.write(f2,
"f2-u1!");
assertNull(ws.poll());
ioService.write(f3,
"f3-u1!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(3,
ioService.write(f1,
"f1-u1!");
assertNull(ws.poll());
ioService.write(f2,
"f2-u2!");
assertNull(ws.poll());
ioService.write(f3,
"f3-u2!");
assertNull(ws.poll());
ioService.endBatch();
List<WatchEvent<?>> events = ws.poll().pollEvents();
assertEquals(2,
我有一个 WatchService 实现,其中服务使用 key = watchService.poll() 或 take() 方法监视目录。但我面临的问题是,如果我在启动 poll() 或 take(
我尝试将一个非常小的文件复制并粘贴到监视服务观察到的文件夹中。第一次效果很好,但在接下来的所有复制和粘贴操作中,我收到一个异常,即另一个进程已经处理该文件。通过实验,我发现我的服务会在 Windows
我正在寻找一种在注册 WatchService 的路径时传递参数的方法。目标是在处理与 Path 相关的事件时获取这些参数。 WatchService watchService = FileSyste
public static void main (String args[]) throws Exception { Path _directotyToWatch = Paths.ge
我正在与我的软件用户合作,当我的软件添加文件夹监视时遇到问题。对 register 的调用似乎永远阻塞。这是来自用户机器的线程转储: platformExecutor [01-12_10:14]" I
我有一个 scala 类,它使用 java nio WatchService 来检测特定目录中新文件夹的创建。 当应用程序运行并且我手动将文件夹复制到目标文件夹时,WatchService 运行良好。
我有以下文件和文件夹结构: /root/ /root/pictures/ /root/pictures/picture1.jpg /root/pictures/picture2.jpg 我注册了两个
我有一个 WatchService 为以下代码抛出一个 ClosedWatchServiceException: final WatchService watchService = FileSyste
我有一个递归监视服务,用于在应用程序运行时监视目录。由于未知原因, watch 服务似乎在大约一天后停止工作。那时,我可以将新文件添加到受监视的目录中,并且不会收到任何日志语句,并且我的观察者不会收到
如何对这样的 watchservice 进行单元测试: /** * Function to look for changes in a determinate directory * @param
我正在尝试使用 Java Watchservice (NIO) 来监视多个目录,我可以在所有目录中看到创建事件,但我无法追溯到创建文件的目录。 例如,每当创建一个新文件时,我只能看到一个文件名(没有路
我想使用 Java 7 WatchService监视 /proc 文件夹,但这不起作用(不报告文件夹中所做的更改)。我已经测试了其他文件夹,例如 /home/user/Desktop 和 /tmp 并
我想每 10 秒轮询一个目录,看看是否有任何文件被添加或修改。如果它们在 10 秒内有任何变化,我想要一组所有文件路径,然后我可以将其传递给另一个方法。 问题 添加文件后,它会立即被识别并调用 add
我一直在研究 java.nio.file.WatchService并注意到 Path s 从 WatchEvent.context() 返回不返回正确的 .toAbsolutePath() .这是一个
我试图将一个非常小的文件复制并粘贴到监视服务观察到的文件夹中。第一次效果很好,但在接下来的所有复制和粘贴操作中,我得到一个异常,另一个进程已经处理了该文件。通过实验,我发现当 Windows 创建文件
我正在使用 java.nio WatchService 来监视文件系统的变化(对于 webapp syncing project )。 但是,当我清理监视的目录时,我遇到一个文件正在使用的问题(事实上
我在使用 WatchService 时遇到问题。这是我的代码片段: public void watch(){ //define a folder root Path myDir = Paths
我实现了一个文件观察器,但我注意到 java nio 文件观察器不会为在映射驱动器上复制的文件生成事件。例如,我在 Unix 上运行文件观察器来观察映射到 windows (H:\) 上的本地目录 (
我正在使用 WatchService 来监视文件夹及其子文件夹中创建的新文件。但是,当创建文件时,WatchService 会给出所创建文件的名称,而不是其位置。有没有办法获取所创建文件的绝对/相对路
我想使用新的 Java 7 WatchService 来监视用户指定的一组目录。在 Windows 7 上,这在本地文件系统和任意复杂的文件树的映射网络驱动器上运行良好。然而,在 Windows XP
我是一名优秀的程序员,十分优秀!