@Test
public void testPublishToStreaming() throws Exception {

  setUpMultiTenant();
  expect(securityService.getOrganization()).andReturn(org1).once();
  expect(securityService.getOrganization()).andReturn(org2).once();
  expect(securityService.getOrganization()).andReturn(org3).once();
  replay(securityService);
  streamingService.activate(bundleContext, map);
  assertTrue(streamingService.publishToStreaming());
  assertTrue(streamingService.publishToStreaming());
  assertFalse(streamingService.publishToStreaming());
}