BloombergLiveDataServer extends AbstractBloombergLiveDataServer { public void setSubscriptionLimit(long subscriptionLimit) { _subscriptionLimit = subscriptionLimit; } BloombergLiveDataServer(BloombergConnector bloombergConnector, ReferenceDataProvider referenceDataProvider, CacheManager cacheManager,
      FudgeMessageSender availabilityNotificationSender); BloombergConnector getBloombergConnector(); long getSubscriptionLimit(); void setSubscriptionLimit(long subscriptionLimit); @Override ReferenceDataProvider getReferenceDataProvider(); RejectedDueToSubscriptionLimitEvent getLastLimitRejection(); @Override synchronized void start(); @Override synchronized void stop(); static void main(String[] args);  }
@Test(groups = {"bbgSubscriptionTests" }, enabled = false) public void testSubscribeLimit() throws Exception { _server.setSubscriptionLimit(0); CollectingLiveDataListener listener = new CollectingLiveDataListener(1, 0); subscribe(_liveDataClient, listener, "AAPL US Equity"); assertTrue(listener.waitUntilEnoughUpdatesReceived(1000)); Thread.sleep(100000); for (LiveDataSubscriptionResponse response : listener.getSubscriptionResponses()) { assertEquals(response.getSubscriptionResult(), LiveDataSubscriptionResult.INTERNAL_ERROR); assertTrue(response.getUserMessage().toLowerCase().contains("limit")); } }