Package org.hive2hive.core.processes.framework.interfaces

Examples of org.hive2hive.core.processes.framework.interfaces.IProcessComponent.start()

65
66
67
68
69
70
71
72
73
74
75
    for (File file : fileBuffer) {
      try {
        IProcessComponent process = fileManager.update(file);
        if (!fileManager.isAutostart()) {
          process.start();
        }
      } catch (IllegalArgumentException | NoSessionException | NoPeerConnectionException
          | InvalidProcessStateException e) {
        logger.error(e.getMessage());
      }
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
    for (File toDelete : bufferedFiles) {
      try {
        logger.debug("Starting to delete buffered file {}.", toDelete);
        IProcessComponent delete = fileManager.delete(toDelete);
        if (!fileManager.isAutostart())
          delete.start();
        delete.await(MAX_DELETION_PROCESS_DURATION_MS);
      } catch (NoSessionException | NoPeerConnectionException | InvalidProcessStateException
          | InterruptedException e) {
        logger.error(e.getMessage());
      }
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
    for (File toAdd : fileBuffer) {
      try {
        IProcessComponent process = fileManager.add(toAdd);
        if (!fileManager.isAutostart())
          process.start();
      } catch (NoSessionException | NoPeerConnectionException | IllegalFileLocation
          | InvalidProcessStateException e) {
        logger.error(e.getMessage());
      }
    }
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
    Set<String> users = new HashSet<String>(1);
    users.add(userACredentials.getUserId());
    CountingNotificationMessageFactory msgFactory = new CountingNotificationMessageFactory(notifier);
    IProcessComponent process = ProcessFactory.instance().createNotificationProcess(msgFactory, users,
        notifier);
    process.start();

    H2HWaiter waiter = new H2HWaiter(20);
    do {
      waiter.tickASecond();
    } while (!msgFactory.allMsgsArrived());
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
    users.add(userBCredentials.getUserId());
    users.add(userCCredentials.getUserId());
    CountingNotificationMessageFactory msgFactory = new CountingNotificationMessageFactory(notifier);
    IProcessComponent process = ProcessFactory.instance().createNotificationProcess(msgFactory, users,
        notifier);
    process.start();

    H2HWaiter waiter = new H2HWaiter(20);
    do {
      waiter.tickASecond();
    } while (!msgFactory.allMsgsArrived());
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);

    // kick out peer 3 (B)
    network.get(3).getConnection().getPeer().setObjectDataReply(new DenyingMessageReplyHandler());
    process.start();

    // wait until all messages are sent
    UseCaseTestUtil.waitTillSucceded(listener, 20);

    H2HWaiter waiter = new H2HWaiter(10);
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
    process.attachListener(listener);

    // kick out peer 3 and 4 (B)
    network.get(3).getConnection().getPeer().setObjectDataReply(new DenyingMessageReplyHandler());
    network.get(4).getConnection().getPeer().setObjectDataReply(new DenyingMessageReplyHandler());
    process.start();

    // wait until all messages are sent
    UseCaseTestUtil.waitTillSucceded(listener, 20);

    H2HWaiter waiter = new H2HWaiter(10);
View Full Code Here
302
303
304
305
306
307
308
309
310
311
312
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);

    // kick out Peer 1
    network.get(1).getConnection().getPeer().setObjectDataReply(new DenyingMessageReplyHandler());
    process.start();

    // wait until all messages are sent
    UseCaseTestUtil.waitTillSucceded(listener, 20);

    // check the locations map; should have 2 entries only
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
      NoPeerConnectionException {
    // upload the same content again
    IProcessComponent process = ProcessFactory.instance().createUpdateFileProcess(file, uploader);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    process.attachListener(listener);
    process.start();

    H2HWaiter waiter = new H2HWaiter(60);
    do {
      waiter.tickASecond();
    } while (!listener.hasFailed());
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
    IProcessComponent loginProcess = ProcessFactory.instance().createLoginProcess(wrongCredentials, sessionParameters,
        client);
    TestProcessComponentListener listener = new TestProcessComponentListener();
    loginProcess.attachListener(listener);
    loginProcess.start();

    UseCaseTestUtil.waitTillFailed(listener, 20);

    return client.getSession();
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.