Examples of com.surftools.BeanstalkClient.Client.watch()

Class com.surftools.BeanstalkClient.Client

Examples of com.surftools.BeanstalkClient.Client.watch()

com.surftools.BeanstalkClient.Client.watch()
The "watch" command adds the named tube to the watch list for the current connection. A reserve command will take a job from any of the tubes in the watch list. For each new connection, the watch list initially consists of one tube, named "default". @param tubeName is a name at most 200 bytes. It specifies a tube to add to the watch list. If the tube doesn't exist, it will be created. @return is the integer number of tubes currently in the watch list.

    } catch (Exception e) {
      fail("caught unexpected exception: " + e.getClass().getCanonicalName() + ", " + e.getMessage());
    }


    try {
      client.watch(null);
      fail("didn't throw");
    } catch (BeanstalkException be) {
      assertEquals("null tubeName", be.getMessage());
    } catch (Exception e) {
      fail("caught unexpected exception: " + e.getClass().getCanonicalName() + ", " + e.getMessage());

View Full Code Here

    assertNotNull(list);
    int initialWatchCount = list.size();
    assertTrue(initialWatchCount >= 1);


    String tubeName = "tube-" + UUID.randomUUID().toString();
    int watchCount = client.watch(tubeName);
    assertEquals(initialWatchCount + 1, watchCount);


    list = client.listTubesWatched();
    assertNotNull(list);
    assertEquals(watchCount, list.size());

View Full Code Here

TOP

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.