@Test (expected = IllegalArgumentException.class) public void testMessageBlockSizeLimit() throws Exception { StringBuilder sb = new StringBuilder(); for (int i = 0; i <= 20 * 1024 * 1024; ++i) { sb.append('a'); } Message message = new Message(ByteBuffer.wrap(sb.toString().getBytes())); List<Message> msgList = new ArrayList<Message>(); msgList.add(message); simpleProducer.putMessageList(msgList); }
public void putMessageList(List<Message> msgList) throws IOException, TException { if (msgList == null || msgList.size() == 0) { return; } for (Message message : msgList) { Utils.updateMessage(message, MessageType.BINARY); } Utils.checkMessageValidity(msgList); doPut(msgList); }
SimpleProducer { public void putMessageList(List<Message> msgList) throws IOException, TException { if (msgList == null || msgList.size() == 0) { return; } for (Message message : msgList) { Utils.updateMessage(message, MessageType.BINARY); } Utils.checkMessageValidity(msgList); doPut(msgList); } }
SimpleProducer { public void putMessageList(List<Message> msgList) throws IOException, TException { if (msgList == null || msgList.size() == 0) { return; } for (Message message : msgList) { Utils.updateMessage(message, MessageType.BINARY); } Utils.checkMessageValidity(msgList); doPut(msgList); } SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleProducer(TalosProducerConfig producerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, MessageService.Iface messageClientMock,
      TopicService.Iface topicClient, AtomicLong requestId,
      ScheduleInfoCache scheduleInfoCacheMock); }
SimpleProducer { public void putMessageList(List<Message> msgList) throws IOException, TException { if (msgList == null || msgList.size() == 0) { return; } for (Message message : msgList) { Utils.updateMessage(message, MessageType.BINARY); } Utils.checkMessageValidity(msgList); doPut(msgList); } SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleProducer(TalosProducerConfig producerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, MessageService.Iface messageClientMock,
      TopicService.Iface topicClient, AtomicLong requestId,
      ScheduleInfoCache scheduleInfoCacheMock); @Deprecated boolean putMessage(List<Message> msgList); void putMessageList(List<Message> msgList); void shutDown(); }
SimpleProducer { public void putMessageList(List<Message> msgList) throws IOException, TException { if (msgList == null || msgList.size() == 0) { return; } for (Message message : msgList) { Utils.updateMessage(message, MessageType.BINARY); } Utils.checkMessageValidity(msgList); doPut(msgList); } SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, MessageService.Iface messageClient,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, Credential credential); @Deprecated  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, Credential credential);  SimpleProducer(TalosProducerConfig producerConfig,
      String topicName, int partitionId, TalosClientFactory talosClientFactory,
      String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig,
      TopicAndPartition topicAndPartition, TalosClientFactory talosClientFactory,
      MessageService.Iface messageClient, String clientId, AtomicLong requestId);  SimpleProducer(TalosProducerConfig producerConfig, String topicName,
      int partitionId, MessageService.Iface messageClientMock,
      TopicService.Iface topicClient, AtomicLong requestId,
      ScheduleInfoCache scheduleInfoCacheMock); @Deprecated boolean putMessage(List<Message> msgList); void putMessageList(List<Message> msgList); void shutDown();  }