Assert.assertEquals("compression is not the same", subMsgRequest.isCompressed(), subMsgResponse.isCompressed());
// disable service
SCMgmtClient clientMgmt = new SCMgmtClient(TestConstants.HOST, TestConstants.PORT_SC0_TCP);
clientMgmt.attach();
clientMgmt.disableService(TestConstants.pubServiceName1);
clientMgmt.detach();
subMsgRequest.setMask(TestConstants.mask1);
subMsgResponse = publishService.changeSubscription(subMsgRequest);
Assert.assertNotNull("the session ID is null", publishService.getSessionId());