Examples of org.serviceconnector.api.cln.SCSessionService

org.serviceconnector.api.cln.SCSessionService

The Class SessionService. SessionService is a remote interface in client API to a session service and provides communication functions. Creating a session service instance for API users should be done by calling SCClient newSessionService().

State Diagram

 ||                                                            |-------execute-------| \/                                                            |                     | |---------|              |----------|                      |--------------|             | | initial |----attach--->| attached |----create session--->| has session  |--echo--|    | |         |<---detach----|          |<---delete session----| with service |<-------|    | |---------|              |----------|                      |--------------|<------------| || \/

After creating a session a delete session must be done in every case at the end of communication. A delete session may be called multiple times. Nothing happens if the session turns inactive in meantime. @author JTraber

    this.startSC0AAndServers();


    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");

View Full Code Here

   */
  @Test
  public void t70_createTwoSessions() throws Exception {
    SCMessage request = new SCMessage();
    SCMessage response = null;
    SCSessionService service1 = client.newSessionService(TestConstants.sesServiceName1);
    SCSessionService service2 = client.newSessionService(TestConstants.sesServiceName1);
    msgCallback1 = new MsgCallback(sessionService1);
    response = service1.createSession(request, msgCallback1);
    Assert.assertNotNull("the session ID is null", service1.getSessionId());
    MsgCallback cbk2 = new MsgCallback(service2);
    response = service2.createSession(request, cbk2);
    Assert.assertNotNull("the session ID is null", service2.getSessionId());


    service1.deleteSession();
    Assert.assertNull("the session ID is NOT null after deleteSession()", service1.getSessionId());
    service2.deleteSession();
    Assert.assertNull("the session ID is NOT null after deleteSession()", service2.getSessionId());
  }

View Full Code Here

  @Test
  public void t30_cc_2Clients1Cache() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");

View Full Code Here

  @Test
  public void t31_cc_2Clients1Cache() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    sessionService1.execute(request);


    // 3: load data to cache (cid=600) by client2
    request.setCacheId("600");
    request.setMessageInfo(TestConstants.cacheCmd);
    sessionService2.execute(request);


    // 4: start cache guardian1 for client2 - do nothing
    SCSubscribeMessage subMsg = new SCSubscribeMessage();
    subMsg.setMask(TestConstants.mask);
    subMsg.setSessionInfo(TestConstants.doNothingCmd);

View Full Code Here

  @Test
  public void t32_cc_2Clients1Cache() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    sessionService1.execute(request);


    // 3: load data to cache (cid=600) by client2
    request.setCacheId("600");
    request.setMessageInfo(TestConstants.cacheCmd);
    sessionService2.execute(request);


    // 4: start cache guardian1 for client2 - do nothing
    SCSubscribeMessage subMsg = new SCSubscribeMessage();
    subMsg.setMask(TestConstants.mask);
    subMsg.setSessionInfo(TestConstants.doNothingCmd);

View Full Code Here

  @Test
  public void t33_cc_2Clients2Server1Cache() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");

View Full Code Here

  @Test
  public void t34_cc_2Clients2Server1Cache() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");

View Full Code Here

  @Test
  public void t34_cc_2Clients2Server1Cache30000Msgs() throws Exception {
    // 1: connect new client2 to top level (cascaded) SC
    SCClient client2 = new SCClient(TestConstants.HOST, sessionClient.getPort(), ConnectionType.NETTY_TCP);
    client2.attach();
    SCSessionService sessionService2 = client2.newSessionService(TestConstants.sesServiceName1);
    sessionService2.createSession(new SCMessage(), new SessionMsgCallback(sessionService2));


    // 2: load data to cache (cid=700) by client1
    SCMessage request = new SCMessage();
    request.setData("cacheFor1Hour_managedData");
    request.setCacheId("700");

View Full Code Here

    request.setMessageInfo(TestConstants.cacheCmd);
    response = sessionService1.execute(request);
    Assert.assertEquals("cacheFor1Hour", response.getData());


    // session service two stores "cacheFor2Hour" with cacheId 600
    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");
    request.setMessageInfo(TestConstants.cacheCmd);
    response = sessionService1.execute(request);
    Assert.assertEquals("cacheFor1Hour", response.getData());
    Assert.assertEquals("700", response.getCacheId());
    Assert.assertEquals("2", response.getCachePartNr());


    // 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("2", response.getCachePartNr());


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


    // 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("2", response.getCachePartNr());


    sessionService2.deleteSession();
    sessionService1.deleteSession();
  }

View Full Code Here

    SCMessage response = null;
    sessionService1 = client.newSessionService(TestConstants.sesServiceName1);
    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
    request.setData("cache10MBStringFor1Hour");
    request.setCacheId("700");
    request.setMessageInfo(TestConstants.cacheCmd);
    sessionService1.send(request);
    // to assure service1 started loading cache
    Thread.sleep(10);
    // 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

0 1 2 3

TOP

Related Classes of org.serviceconnector.api.cln.SCSessionService

org.serviceconnector.api.SCAppendMessage

org.serviceconnector.api.SCManagedMessage

org.serviceconnector.api.SCMessage

org.serviceconnector.cache.SC_CACHING_METHOD

org.serviceconnector.call.SCMPClnCreateSessionCall

org.serviceconnector.call.SCMPClnDeleteSessionCall

org.serviceconnector.call.SCMPClnExecuteCall

org.serviceconnector.call.SCMPEchoCall

org.serviceconnector.cln.DemoCCClient

org.serviceconnector.cln.DemoSessionCacheClient

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.