We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 7a7e594 + cb6604d commit d7a543fCopy full SHA for d7a543f
src/main/java/com/cisco/trex/stateless/TRexTransport.java
@@ -149,21 +149,6 @@ public synchronized String sendJson(String json) {
149
msg = zmqSocket.recv();
150
}
151
152
- if (msg == null) {
153
- zmqSocket.connect(this.connectionString);
154
- try {
155
- zmqSocket.send(compressed);
156
- } catch (ZMQException e) {
157
- throw new IllegalStateException(
158
- "Did not get any response from server "
159
- + getHost()
160
- + " within timeout "
161
- + zmqSocket.getReceiveTimeOut(),
162
- e);
163
- }
164
- msg = zmqSocket.recv();
165
166
-
167
String response = this.dataCompressor.decompressBytesToString(msg);
168
LOGGER.debug("JSON Resp: {}", response);
169
return response;
0 commit comments