Examples of org.serviceconnector.api.cln.SCPublishService.subscribe()

Class org.serviceconnector.api.cln.SCPublishService

Examples of org.serviceconnector.api.cln.SCPublishService.subscribe()

org.serviceconnector.api.cln.SCPublishService.subscribe()
Subscribe to SC with default operation timeout.
Once a subscribe is called a unsubscribe need to be done at the end of a communication. @param scSubscribeMessage the SC subscribe message @param scMessageCallback the SC message callback @return the SC subscribe message @throws SCMPValidatorException subscribe message is null
callback is null
mask is invalid
@throws SCServiceException instance already subscribed before
subscribe to host failed
error message received from SC

      String mask = "0000121ABCDEFGHIJKLMNO-----------X-----------";
      msg.setSessionInfo("subscription-info"); // optional
      msg.setData("certificate or what so ever"); // optional
      msg.setMask(mask); // mandatory
      msg.setNoDataIntervalSeconds(100); // mandatory
      SCSubscribeMessage reply = service.subscribe(msg, cbk); // regular subscribe


      String sid = service.getSessionId();


      // wait to receive messages
      while (cbk.receivedMsg < 5) {

View Full Code Here

      String mask = "0000121ABCDEFGHIJKLMNO-----------X-----------";
      subMsg.setSessionInfo("subscription-info"); // optional
      subMsg.setData("certificate or what so ever"); // optional
      subMsg.setMask(mask); // mandatory
      subMsg.setNoDataIntervalSeconds(100); // mandatory
      SCSubscribeMessage subReply = publishService.subscribe(subMsg, pubCbk); // regular subscribe
      
      responseMsg = sessionSrv.execute(requestMsg); // regular synchronous call
      LOGGER.info("Message sent with cacheId=" + requestMsg.getData());
      LOGGER.info("Message received from cache=" + responseMsg.getData());

View Full Code Here

    Assert.assertEquals("message body is not the same length", subMsgRequest.getDataLength(), subMsgResponse.getDataLength());
    Assert.assertEquals("compression is not the same", subMsgRequest.isCompressed(), subMsgResponse.isCompressed());
    Assert.assertTrue("is not subscribed", service1.isSubscribed());


    subMsgRequest.setSessionInfo(TestConstants.publishCompressedMsgCmd);
    subMsgResponse = service2.subscribe(subMsgRequest, cbk2);
    Assert.assertNotNull("the session ID is null", service2.getSessionId());
    Assert.assertEquals("message body is not the same length", subMsgRequest.getDataLength(), subMsgResponse.getDataLength());
    Assert.assertEquals("compression is not the same", subMsgRequest.isCompressed(), subMsgResponse.isCompressed());
    Assert.assertTrue("is not subscribed", service2.isSubscribed());

View Full Code Here

    SCMessage scMessage = new SCMessage();
    sessService.createSession(scMessage, new TestSessionServiceMessageCallback(sessService));
    SCPublishService pubService = client.newPublishService(TestConstants.pubServerName1);
    SCSubscribeMessage scSubscribeMessage = new SCSubscribeMessage();
    scSubscribeMessage.setMask(TestConstants.mask);
    pubService.subscribe(scSubscribeMessage, new TestPublishServiceMessageCallback(pubService));


    SCPublishService pubService1 = client.newPublishService(TestConstants.pubServiceName1);
    scSubscribeMessage.setNoDataIntervalSeconds(40);
    pubService1.subscribe(scSubscribeMessage, new TestPublishServiceMessageCallback(pubService1));

View Full Code Here

    scSubscribeMessage.setMask(TestConstants.mask);
    pubService.subscribe(scSubscribeMessage, new TestPublishServiceMessageCallback(pubService));


    SCPublishService pubService1 = client.newPublishService(TestConstants.pubServiceName1);
    scSubscribeMessage.setNoDataIntervalSeconds(40);
    pubService1.subscribe(scSubscribeMessage, new TestPublishServiceMessageCallback(pubService1));


    System.out.println("APISessionSubscriptionTest.t01_()");


    try {
      sessService.deleteSession();

View Full Code Here

      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) {
      e.printStackTrace();
    } finally {
      try {
        // disconnects from SC

View Full Code Here


    MsgCallback cbk1 = new MsgCallback(service1);
    MsgCallback cbk2 = new MsgCallback(service2);


    subMsgResponse = service1.subscribe(subMsgRequest, cbk1);
    subMsgResponse = service2.subscribe(subMsgRequest, cbk2);


    // destroy the server
    SystemSuperTest.ctrl.stopServerEnvironment(SystemSuperTest.srvCtxs);
    cbk1.waitForMessage(2);
    cbk2.waitForMessage(2);

View Full Code Here


    MsgCallback cbk1 = new MsgCallback(service1);
    MsgCallback cbk2 = new MsgCallback(service2);


    subMsgResponse = service1.subscribe(subMsgRequest, cbk1);
    subMsgResponse = service2.subscribe(subMsgRequest, cbk2);


    // destroy the server
    SystemSuperTest.ctrl.stopServerEnvironment(SystemSuperTest.srvCtxs);
    cbk1.waitForMessage(2);
    cbk2.waitForMessage(2);

View Full Code Here

    Assert.assertNotNull("the session ID is null", service1.getSessionId());
    Assert.assertEquals("message body is not the same length", subMsgRequest.getDataLength(), subMsgResponse.getDataLength());
    Assert.assertEquals("compression is not the same", subMsgRequest.isCompressed(), subMsgResponse.isCompressed());
    Assert.assertTrue("is not subscribed", service1.isSubscribed());


    subMsgResponse = service2.subscribe(subMsgRequest, cbk2);
    Assert.assertNotNull("the session ID is null", service2.getSessionId());
    Assert.assertEquals("message body is not the same length", subMsgRequest.getDataLength(), subMsgResponse.getDataLength());
    Assert.assertEquals("compression is not the same", subMsgRequest.isCompressed(), subMsgResponse.isCompressed());
    Assert.assertTrue("is not subscribed", service2.isSubscribed());

View Full Code Here


    MsgCallback cbk1 = new MsgCallback(service1);
    MsgCallback cbk2 = new MsgCallback(service2);


    subMsgResponse = service1.subscribe(subMsgRequest, cbk1);
    subMsgResponse = service2.subscribe(subMsgRequest, cbk2);


    // destroy the server
    SystemSuperTest.ctrl.stopServerEnvironment(SystemSuperTest.srvCtxs);
    cbk1.waitForMessage(2);
    cbk2.waitForMessage(2);

View Full Code Here

0 1

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.