Skip to content

Commit 32383ce

Browse files
committed
Use commons-lang3
1 parent 986e1fb commit 32383ce

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/AmqpConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
import lombok.Getter;
3636
import lombok.extern.log4j.Log4j2;
3737
import org.apache.bookkeeper.util.collections.ConcurrentLongLongHashMap;
38-
import org.apache.commons.lang.StringUtils;
38+
import org.apache.commons.lang3.StringUtils;
3939
import org.apache.pulsar.broker.authentication.AuthenticationProvider;
4040
import org.apache.pulsar.broker.authentication.AuthenticationState;
4141
import org.apache.pulsar.broker.namespace.LookupOptions;

amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/proxy/ProxyConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ public void receiveConnectionOpen(AMQShortString virtualHost, AMQShortString cap
237237
String virtualHostStr = AMQShortString.toString(virtualHost);
238238
if ((virtualHostStr != null) && virtualHostStr.charAt(0) == '/') {
239239
virtualHostStr = virtualHostStr.substring(1);
240-
if (org.apache.commons.lang.StringUtils.isEmpty(virtualHostStr)){
240+
if (org.apache.commons.lang3.StringUtils.isEmpty(virtualHostStr)){
241241
virtualHostStr = AmqpConnection.DEFAULT_NAMESPACE;
242242
}
243243
}

amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/proxy/PulsarServiceLookupHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import java.util.Optional;
2323
import java.util.concurrent.CompletableFuture;
2424
import lombok.extern.slf4j.Slf4j;
25-
import org.apache.commons.lang.StringUtils;
25+
import org.apache.commons.lang3.StringUtils;
2626
import org.apache.commons.lang3.tuple.Pair;
2727
import org.apache.pulsar.broker.PulsarService;
2828
import org.apache.pulsar.broker.resources.MetadataStoreCacheLoader;

0 commit comments

Comments
 (0)