File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
pulsar-client/src/main/java/org/apache/pulsar/client/impl Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change 2222import java .util .ArrayList ;
2323import java .util .Iterator ;
2424import java .util .List ;
25- import lombok .extern .slf4j .Slf4j ;
2625import net .jcip .annotations .NotThreadSafe ;
2726import org .apache .pulsar .client .api .Message ;
2827import org .apache .pulsar .client .api .Messages ;
2928
3029@ NotThreadSafe
31- @ Slf4j
3230public class MessagesImpl <T > implements Messages <T > {
3331
3432 private final List <Message <T >> messageList ;
@@ -51,14 +49,10 @@ protected boolean canAdd(Message<T> message) {
5149 return true ;
5250 }
5351 if (maxNumberOfMessages > 0 && currentNumberOfMessages + 1 > maxNumberOfMessages ) {
54- log .warn ("can't add message to the container, has exceeded the maxNumberOfMessages : {} " ,
55- maxNumberOfMessages );
5652 return false ;
5753 }
5854
5955 if (maxSizeOfMessages > 0 && currentSizeOfMessages + message .size () > maxSizeOfMessages ) {
60- log .warn ("can't add message to the container, has exceeded the maxSizeOfMessages : {} " ,
61- maxSizeOfMessages );
6256 return false ;
6357 }
6458
You can’t perform that action at this time.
0 commit comments