diff --git a/plugins/protocol/servicebus/pom.xml b/plugins/protocol/servicebus/pom.xml
index 1ea370f..e57a4a1 100644
--- a/plugins/protocol/servicebus/pom.xml
+++ b/plugins/protocol/servicebus/pom.xml
@@ -4,7 +4,7 @@
 
     <groupId>jp.co.pnop</groupId>
     <artifactId>jmeter-plugins-azure-servicebus</artifactId>
-    <version>0.3.1</version>
+    <version>0.3.2</version>
 
     <name>Azure Service Bus Sampler</name>
     <description>Sample to Azure Service Bus</description>
diff --git a/plugins/protocol/servicebus/src/main/java/jp/co/pnop/jmeter/protocol/azureservicebus/common/AzServiceBusClientParams.java b/plugins/protocol/servicebus/src/main/java/jp/co/pnop/jmeter/protocol/azureservicebus/common/AzServiceBusClientParams.java
index a4e6784..f40eaca 100644
--- a/plugins/protocol/servicebus/src/main/java/jp/co/pnop/jmeter/protocol/azureservicebus/common/AzServiceBusClientParams.java
+++ b/plugins/protocol/servicebus/src/main/java/jp/co/pnop/jmeter/protocol/azureservicebus/common/AzServiceBusClientParams.java
@@ -3,7 +3,6 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import com.azure.core.amqp.AmqpTransportType;
-import com.azure.core.amqp.ProxyOptions;
 import com.azure.messaging.servicebus.ServiceBusClientBuilder;
 import com.azure.messaging.servicebus.ServiceBusSenderClient;
 
@@ -13,7 +12,6 @@
 import org.slf4j.LoggerFactory;
 
 import jp.co.pnop.jmeter.protocol.aad.config.AzAdCredential;
-import jp.co.pnop.jmeter.protocol.aad.config.AzAdCredential.AzAdCredentialComponentImpl;
 import jp.co.pnop.jmeter.protocol.amqp.util.AzAmqpProxyOptions;
 import jp.co.pnop.jmeter.protocol.azureservicebus.config.AzServiceBusClient.AzServiceBusClientComponentImpl;
 
@@ -181,7 +179,7 @@ public ServiceBusSenderClient getProducer() throws Exception {
             }
 
             AmqpTransportType protocol = null;
-            if (getProtocol() == PROTOCOL_AMQP_OVER_WEBSOCKETS) {
+            if (getProtocol().equals(PROTOCOL_AMQP_OVER_WEBSOCKETS)) {
                 protocol = AmqpTransportType.AMQP_WEB_SOCKETS;
                 producerBuilder.proxyOptions(new AzAmqpProxyOptions().ProxyOptions());
             } else {