Package org.serviceconnector.api.cln

Examples of org.serviceconnector.api.cln.SCMessageCallback

63
64
65
66
67
68
69
70
71
72
73
      service.setEchoTimeoutSeconds(2); // can be set before create session

      SCMessage msg = new SCMessage();
      msg.setSessionInfo("session-info"); // optional
      msg.setData("certificate or what so ever"); // optional
      SCMessageCallback cbk = new DemoSessionClientCallback(service); // callback on service!!
      SCMessage reply = service.createSession(10, msg, cbk); // create a session within 10 seconds
      Object body = reply.getData();

      String sid = service.getSessionId();
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
      service.setEchoTimeoutSeconds(2); // can be set before create session

      SCMessage msg = new SCMessage();
      msg.setSessionInfo("session-info"); // optional
      msg.setData("certificate or what so ever"); // optional
      SCMessageCallback cbk = new DemoSessionClientCallback(service); // callback on service!!
      service.createSession(10, msg, cbk); // alternative with operation timeout and message
      // service.createSession(msg); // alternative with message

      String sid = service.getSessionId();
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
      SCSessionService sessionServiceA = sc.newSessionService("session-1");
      // creates a session
      SCMessage scMessage = new SCMessage();
      scMessage.setSessionInfo("sessionInfo");
      sessionServiceA.setEchoTimeoutSeconds(300);
      SCMessageCallback cbk = new ExampleCallback(sessionServiceA);
      sessionServiceA.createSession(60, scMessage, cbk);

      SCMessage requestMsg = new SCMessage();
      requestMsg.setData("Hello World");
      requestMsg.setCompressed(false);
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
      SCSessionService sessionServiceA = sc.newSessionService("session-1");
      // creates a session
      SCMessage scMessage = new SCMessage();
      scMessage.setSessionInfo("sessionInfo");
      sessionServiceA.setEchoTimeoutSeconds(300);
      SCMessageCallback cbk = new ExampleCallback(sessionServiceA);
      sessionServiceA.createSession(60, scMessage, cbk);

      SCMessage requestMsg = new SCMessage();
      // set up large buffer
      byte[] buffer = new byte[9000000];
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
      SCSessionService sessionServiceA = sc.newSessionService("session-1");
      // creates a session
      SCMessage scMessage = new SCMessage();
      scMessage.setSessionInfo("sessionInfo");
      sessionServiceA.setEchoTimeoutSeconds(300);
      SCMessageCallback cbk = new ExampleCallback(sessionServiceA);
      sessionServiceA.createSession(60, scMessage, cbk);

      SCMessage requestMsg = new SCMessage();
      requestMsg.setData("Hello World");
      requestMsg.setCompressed(false);
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
      sessionSrv.setEchoTimeoutSeconds(2); // can be set before create session

      SCMessage msg = new SCMessage();
      msg.setSessionInfo("session-info"); // optional
      msg.setData("certificate or what so ever"); // optional
      SCMessageCallback cbk = new DemoSessionClientCallback(sessionSrv); // callback on service!!
      SCMessage reply = sessionSrv.createSession(10, msg, cbk); // create a session within 10 seconds
      Object body = reply.getData();   
     
      String sid = sessionSrv.getSessionId();
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
      // connects to SC, checks connection to SC
      sc.attach();

      publishServiceA = sc.newPublishService("publish-1");
      SCMessageCallback callback = new TestPublishCallback(publishServiceA);
      SCSubscribeMessage subscibeMessage = new SCSubscribeMessage();
      subscibeMessage.setMask("000012100012832102FADF-----------X-----------");
      subscibeMessage.setSessionInfo("sessionInfo");
      publishServiceA.subscribe(subscibeMessage, callback);
    } catch (Exception e) {
View Full Code Here
364
365
366
367
368
369
370
371
372
373
374
          }
        } else {
          // Subscribe with KILL command
          SCPublishService scPublishService = clientMgmt.newPublishService(serviceName);
          SCSubscribeMessage scMessage = new SCSubscribeMessage();
          SCMessageCallback cbk = new TestPublishServiceMessageCallback(scPublishService);
          scMessage.setSessionInfo(TestConstants.killServerCmd);
          scMessage.setMask("ABCD"); // dummy (mask may not be empty)
          try {
            scPublishService.subscribe(scMessage, cbk);
          } catch (SCServiceException ex) {
View Full Code Here
TOP

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

  • org.serviceconnector.cln.DemoCCClient
  • org.serviceconnector.cln.DemoSessionCacheClient
  • org.serviceconnector.cln.DemoSessionClient
  • org.serviceconnector.cln.SCAsyncSessionClientExample
  • org.serviceconnector.cln.SCLargeMessageSessionClientExample
  • org.serviceconnector.cln.SCPublishClientExample
  • org.serviceconnector.cln.SCSyncSessionClientExample
  • org.serviceconnector.ctrl.util.ProcessesController
    • 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.