Package org.serviceconnector.api.cln

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


    msgCallback1 = new MsgCallback(sessionService1);
    response = sessionService1.createSession(request, msgCallback1);

    SCSessionService sessionService2 = client.newSessionService(TestConstants.sesServiceName1);
    MsgCallback msgCallback2 = new MsgCallback(sessionService1);
    response = sessionService2.createSession(request, msgCallback2);

    // session service starts storing large message with cacheId 700
    String largeMessage = TestUtil.get10MBString();
    request.setData(largeMessage);
    request.setCacheId("700");
View Full Code Here


    Thread.sleep(10000);

    // session service2 starts getting large message from cache with cacheId 700
    SCSessionService sessionService2 = client.newSessionService(TestConstants.sesServiceName1);
    MsgCallback msgCallback2 = new MsgCallback(sessionService1);
    response = sessionService2.createSession(request, msgCallback2);
    request.setData("randomContent");
    request.setCacheId("700");
    response = sessionService2.execute(request);
    Assert.assertEquals(largeMessage, response.getData());
View Full Code Here

    response = sessionService1.createSession(request, msgCallback1);

    SCSessionService sessionService2 = client.newSessionService(TestConstants.sesServiceName1);
    MsgCallback msgCallback2 = new MsgCallback(sessionService1);
    sessionService2.setEchoIntervalSeconds(10);
    response = sessionService2.createSession(request, msgCallback2);

    // session service starts storing message with cacheId 700
    request.setData("cacheWait15sec");
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
View Full Code Here

      if (getMethodName() == "createSession_whiteSpaceSessionInfo_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo(" ");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.deleteSession();

      } else if (getMethodName() == "createSession_arbitrarySpaceSessionInfo_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
View Full Code Here

      } else if (getMethodName() == "createSession_arbitrarySpaceSessionInfo_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("The quick brown fox jumps over a lazy dog.");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.deleteSession();

      } else if (getMethodName() == "createSession_arbitrarySpaceSessionInfoDataOneChar_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage("a");
View Full Code Here

      } else if (getMethodName() == "createSession_arbitrarySpaceSessionInfoDataOneChar_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage("a");
        scMessage.setSessionInfo("The quick brown fox jumps over a lazy dog.");
        sessionService.createSession(10, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.deleteSession();

      } else if (getMethodName() == "createSession_256LongSessionInfoData60kBByteArray_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage(new byte[TestConstants.dataLength60kB]);
View Full Code Here

      } else if (getMethodName() == "createSession_256LongSessionInfoData60kBByteArray_sessionIdIsNotEmpty") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage(new byte[TestConstants.dataLength60kB]);
        scMessage.setSessionInfo(TestConstants.stringLength256);
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.deleteSession();

      } else if (getMethodName() == "deleteSession_beforeCreateSession_noSessionId") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        sessionService.deleteSession();
View Full Code Here

      } else if (getMethodName() == "deleteSession_afterValidNewSessionService_noSessionId") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        sessionService.deleteSession();

      } else if (getMethodName() == "createSession_rejectTheSessionThenCreateValidSessionThenExecuteAMessage_passes") {
        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);
View Full Code Here

        SCSessionService sessionService = client.newSessionService(TestConstants.sesServiceName1);

        try {
          SCMessage scMessage = new SCMessage("reject");
          scMessage.setSessionInfo("sessionInfo");
          sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        } catch (Exception e) {
        }
        SCMessage scMessage = new SCMessage();
        scMessage.setSessionInfo("sessionInfo");
        sessionService.createSession(10, scMessage, new TestSessionServiceMessageCallback(sessionService));
View Full Code Here

          sessionService.createSession(60, scMessage, new TestSessionServiceMessageCallback(sessionService));
        } catch (Exception e) {
        }
        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") {
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.