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 22
22
import java .util .ArrayList ;
23
23
import java .util .Iterator ;
24
24
import java .util .List ;
25
- import lombok .extern .slf4j .Slf4j ;
26
25
import net .jcip .annotations .NotThreadSafe ;
27
26
import org .apache .pulsar .client .api .Message ;
28
27
import org .apache .pulsar .client .api .Messages ;
29
28
30
29
@ NotThreadSafe
31
- @ Slf4j
32
30
public class MessagesImpl <T > implements Messages <T > {
33
31
34
32
private final List <Message <T >> messageList ;
@@ -51,14 +49,10 @@ protected boolean canAdd(Message<T> message) {
51
49
return true ;
52
50
}
53
51
if (maxNumberOfMessages > 0 && currentNumberOfMessages + 1 > maxNumberOfMessages ) {
54
- log .warn ("can't add message to the container, has exceeded the maxNumberOfMessages : {} " ,
55
- maxNumberOfMessages );
56
52
return false ;
57
53
}
58
54
59
55
if (maxSizeOfMessages > 0 && currentSizeOfMessages + message .size () > maxSizeOfMessages ) {
60
- log .warn ("can't add message to the container, has exceeded the maxSizeOfMessages : {} " ,
61
- maxSizeOfMessages );
62
56
return false ;
63
57
}
64
58
You can’t perform that action at this time.
0 commit comments