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 eb6af6eCopy full SHA for eb6af6e
src/main/java/com/cisco/trex/stateless/TRexTransport.java
@@ -164,6 +164,21 @@ public synchronized String sendJson(String json) {
164
msg = zmqSocket.recv();
165
}
166
167
+ if (msg == null) {
168
+ zmqSocket.connect(this.connectionString);
169
+ try {
170
+ zmqSocket.send(compressed);
171
+ } catch (ZMQException e) {
172
+ throw new IllegalStateException(
173
+ "Did not get any response from server "
174
+ + getHost()
175
+ + " within timeout "
176
+ + zmqSocket.getReceiveTimeOut(),
177
+ e);
178
+ }
179
+ msg = zmqSocket.recv();
180
181
+
182
String response = this.dataCompressor.decompressBytesToString(msg);
183
LOGGER.debug("JSON Resp: {}", response);
184
return response;
0 commit comments