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

Class org.serviceconnector.api.cln.SCSessionService

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

org.serviceconnector.api.cln.SCSessionService.execute()
Execute with default operation timeout. Execute is a synchronous operation with the SC. Any reply will be received as return of the method. @param requestMsg the request message @return the SC message @throws SCServiceException session not active (not created yet or dead)
pending request, no second request allowed
execute on SC failed
error message received from SC
@throws SCMPValidatorException execute message is null

    SCSessionService sessionService2 = client.newSessionService(TestConstants.sesServiceName1);
    MsgCallback msgCallback2 = new MsgCallback(sessionService1);
    response = sessionService2.createSession(request, msgCallback2);
    request.setData("cacheFor2Hour");
    request.setCacheId("600");
    response = sessionService2.execute(request);
    Assert.assertEquals("cacheFor2Hour", response.getData());


    // session service one gets message with cacheId 700
    request.setData(TestConstants.pangram);
    request.setCacheId("700");

View Full Code Here


    // session service two gets message with cacheId 600
    request.setData(TestConstants.pangram);
    request.setCacheId("600");
    request.setMessageInfo(TestConstants.cacheCmd);
    response = sessionService2.execute(request);
    Assert.assertEquals("cacheFor2Hour", response.getData());
    Assert.assertEquals("600", response.getCacheId());
    Assert.assertEquals("1", response.getCachePartNr());


    // session service one gets message with cacheId 600

View Full Code Here


    // session service two gets message with cacheId 700
    request.setData(TestConstants.pangram);
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    response = sessionService2.execute(request);
    Assert.assertEquals("cacheFor1Hour", response.getData());
    Assert.assertEquals("700", response.getCacheId());
    Assert.assertEquals("1", response.getCachePartNr());


    sessionService2.deleteSession();

View Full Code Here

    // session service2 starts getting large message from cache with cacheId 700
    request.setData("randomContent");
    request.setMessageInfo(null);
    request.setCacheId("700");
    try {
      response = sessionService2.execute(request);
      Thread.sleep(500);
      Assert.fail("should throw exception");
    } catch (SCServiceException e) {
      Assert.assertEquals(SCMPError.CACHE_LOADING.getErrorCode(), e.getSCErrorCode());
    }

View Full Code Here

    // session service2 starts getting large message from cache with cacheId 700
    request.setData(TestConstants.pangram);
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    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());
    }
    // get response from sessionService1 request

View Full Code Here

      Assert.assertEquals(SCMPError.CACHE_LOADING.getErrorCode(), e.getSCErrorCode());
    }
    // get response from sessionService1 request
    msgCallback1.waitForMessage(60);
    response = msgCallback1.getResponse();
    SCMessage response2 = sessionService2.execute(request);
    Assert.assertEquals(response.getData(), response2.getData());
  }


  /**
   * Description: sessionService exchange a large message, sessionService1 exchange a message, with same cacheId's on two service

View Full Code Here

    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());


    // session service1 get message
    msgCallback1.waitForMessage(60);
    response = msgCallback1.getResponse();

View Full Code Here

    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

    }
    Thread.sleep(5000);
    // get response from sessionService1 request
    msgCallback1.waitForMessage(60);
    response = msgCallback1.getResponse();
    SCMessage response2 = sessionService2.execute(request);
    Assert.assertEquals("cacheWait15sec", response.getData());
  }


  /**
   * Description: exchange message no caching<br>

View Full Code Here

    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());
    // Verify cached flag is set correctly
    Assert.assertTrue("cached flag wrong value", response.isCached());
  }
}

View Full Code Here

0 1 2 3

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.