Package org.rioproject.gnostic.service.test

Examples of org.rioproject.gnostic.service.test.TestService

42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
    }

    @Test
    public void verifyThatInvocationsOnTestServiceAreDisallowedIfUtilizationIsBreached() {
        Assert.assertNotNull(testManager);
        TestService t = testManager.waitForService(TestService.class);
        Assert.assertNotNull(t);
        Throwable thrown = null;
        try {
            long waited = 0;
            long duration = 1000;
            while(t.getStatus().equals(TestService.Status.ALLOWED) && waited<=WAIT) {
                try {
                    Thread.sleep(duration);
                } catch (InterruptedException e) {
                    Thread.interrupted();
                }
                waited += duration;
            }
            Assert.assertTrue("Got "+t.getStatus().name(), t.getStatus().equals(TestService.Status.DISALLOWED));
        } catch (IOException e) {
            thrown = e;
            e.printStackTrace();
        }
        Assert.assertNull(thrown);
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
        } catch (Throwable e) {
            e.printStackTrace();
            thrown = e;
        }
        Assert.assertNull(thrown);
        TestService test = (TestService)testManager.waitForService("Test");
        Util.waitForRule(g, "CounterNotification");
       
        thrown = null;
        boolean written = false;
        for(int i=0; i<50; i++) {
            try {
                test.sendNotify();
                Util.sleep(1000);
                if(i>15 && !written) {
                    writeRule(25, 45, "src/test/resources/CounterNotification.drl");
                    written = true;
                }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
        Assert.assertNotNull(testManager);
        File opstring = new File("src/test/opstring/artifactNotification2.groovy");
        Assert.assertTrue(opstring.exists());
        OperationalStringManager mgr = testManager.deploy(opstring);
        testManager.waitForDeployment(mgr);
        TestService test = (TestService)testManager.waitForService("Test");
        thrown = null;
        Gnostic g = (Gnostic)testManager.waitForService(Gnostic.class);
        Util.waitForRule(g, "CounterNotification");
        for(int i=0; i<15; i++) {
            try {
                test.sendNotify();
                Util.sleep(1000);
            } catch (Exception e) {
                e.printStackTrace();
                thrown = e;
            }
View Full Code Here
TOP

Related Classes of org.rioproject.gnostic.service.test.TestService

  • org.rioproject.gnostic.service.ITNotificationUsingArtifactTest
  • org.rioproject.gnostic.service.ITSystemUtilizationTest
    • Copyright © 2018 www.massapicom. 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.