Package org.serviceconnector.api.cln

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

368
369
370
371
372
373
374
375
376
377
378
          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) {
          }
        }
        clientMgmt.detach();
        FileUtility.waitNotExistsOrUnlocked(srvProcess.getPidFileName(), timeout);
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
      subscibeMessage.setMask(TestConstants.mask);
      subscibeMessage.setSessionInfo("sessionInfo");

      if (getMethodName() == "subscribe_serviceNameValidMaskSameAsInServer_isSubscribedSessionIdExists") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "subscribe_timeoutMaxAllowed_isSubscribedSessionIdExists") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(3600, subscibeMessage, new TestPublishServiceMessageCallback(service));
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "subscribe_timeoutMaxAllowed_isSubscribedSessionIdExists") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(3600, subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "changeSubscription_toMaskWhiteSpace_passes") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
        service.subscribe(3600, subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "changeSubscription_toMaskWhiteSpace_passes") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        subscibeMessage.setMask(" ");
        service.changeSubscription(subscibeMessage);
        service.unsubscribe();

      } else if (getMethodName() == "subscribeUnsubscribe_twice_isSubscribedThenNot") {
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        service.changeSubscription(subscibeMessage);
        service.unsubscribe();

      } else if (getMethodName() == "subscribeUnsubscribe_twice_isSubscribedThenNot") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "changeSubscription_twice_passes") {
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
      } else if (getMethodName() == "subscribeUnsubscribe_twice_isSubscribedThenNot") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "changeSubscription_twice_passes") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));
        service.unsubscribe();

      } else if (getMethodName() == "changeSubscription_twice_passes") {
        SCPublishService service = sc.newPublishService(TestConstants.pubServiceName1);
        service.subscribe(subscibeMessage, new TestPublishServiceMessageCallback(service));

        service.changeSubscription(subscibeMessage);
        service.changeSubscription(subscibeMessage);

        service.unsubscribe();
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
    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
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.