Package org.serviceconnector.api.cln

Examples of org.serviceconnector.api.cln.SCSessionService.execute()

650
651
652
653
654
655
656
657
658
659
660
    request.setData(TestConstants.pangram);
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    for (int i = 0; i < 12; i++) {
      try {
        response = sessionService2.execute(request);
        Assert.fail("Should throw an exception but did not.");
      } catch (SCServiceException e) {
        Assert.assertEquals(SCMPError.CACHE_LOADING.getErrorCode(), e.getSCErrorCode());
      }
      Thread.sleep(1000);
View Full Code Here
661
662
663
664
665
666
667
668
669
    }
    Thread.sleep(5000);
    // get response from sessionService1 request
    msgCallback1.waitForMessage(60);
    response = msgCallback1.getResponse();
    SCMessage response2 = sessionService2.execute(request);
    Assert.assertEquals("cacheWait15sec", response.getData());
  }
}
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        }
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(10, scMessage, new TestSessionServiceMessageCallback(sessionService));

        sessionService.execute(new SCMessage());
        sessionService.deleteSession();

      } else if (getMethodName() == "execute_messageData1MBArray_returnsTheSameMessageData") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));

        SCMessage message = new SCMessage(new byte[TestConstants.dataLength1MB]);
        message.setCompressed(false);

        sessionService.execute(message);
        sessionService.deleteSession();

      } else if (getMethodName() == "createSessionExecuteDeleteSession_twice_6MessagesArrive") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);

        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.execute(new SCMessage(new byte[128]));
        sessionService.deleteSession();

        scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
        sessionService.deleteSession();

        scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.execute(new SCMessage(new byte[128]));
        sessionService.deleteSession();

      } else if (getMethodName() == "echo_waitFor3EchoMessages_5MessagesArrive") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
      sc.attach();
      SCSessionService service = sc.newSessionService(TestConstants.sesServiceName1);
      SCMessage scMessage = new SCMessage();
      scMessage.setSessionInfo("sessionInfo");
      service.createSession(300, scMessage, new TestSessionServiceMessageCallback(service));
      response = service.execute(new SCMessage("executed"));
      service.deleteSession();
      sc.detach();
    } catch (Exception e) {
    }
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
        }
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(10, scMessage, new TestSessionServiceMessageCallback(sessionService));

        sessionService.execute(new SCMessage());
        sessionService.deleteSession();

      } else if (getMethodName() == "execute_messageData1MBArray_returnsTheSameMessageData") {
        SCSessionService sessionService = sc.newSessionService(TestConstants.pubServiceName1);
        SCMessage scMessage = new SCMessage();
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
        sessionService.createSession(10, scMessage, new TestSessionServiceMessageCallback(sessionService));

        SCMessage message = new SCMessage(new byte[TestConstants.dataLength1MB]);
        message.setCompressed(false);

        sessionService.execute(message);
        sessionService.deleteSession();

      }

    } catch (Exception e) {
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        SCSessionService service = sc.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        service.createSession(300, scMessage, new TestSessionServiceMessageCallback(service));
        for (int j = 0; j < executeCycles; j++) {
          service.execute(new SCMessage(new byte[messageSize]));
          counter.increment();
        }
        service.deleteSession();
      }
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.