|
4 | 4 | */ |
5 | 5 | package JMeter.plugins.functional.samplers.websocket; |
6 | 6 |
|
7 | | -import java.io.IOException; |
8 | | -import java.text.SimpleDateFormat; |
9 | | -import java.util.Date; |
10 | | -import java.util.Deque; |
11 | | -import java.util.concurrent.ConcurrentLinkedDeque; |
12 | | -import java.util.concurrent.CountDownLatch; |
13 | | -import java.util.concurrent.TimeUnit; |
14 | | - |
15 | | -import org.apache.log.Logger; |
16 | | - |
17 | | -import java.util.concurrent.atomic.AtomicInteger; |
18 | | -import java.util.regex.Pattern; |
19 | | - |
20 | 7 | import org.apache.jmeter.engine.util.CompoundVariable; |
21 | 8 | import org.apache.jorphan.logging.LoggingManager; |
| 9 | +import org.apache.log.Logger; |
| 10 | +import org.eclipse.jetty.websocket.api.BatchMode; |
22 | 11 | import org.eclipse.jetty.websocket.api.Session; |
23 | 12 | import org.eclipse.jetty.websocket.api.StatusCode; |
24 | 13 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; |
25 | 14 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; |
26 | | -import org.eclipse.jetty.websocket.api.annotations.OnWebSocketFrame; |
27 | 15 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; |
28 | 16 | import org.eclipse.jetty.websocket.api.annotations.WebSocket; |
29 | | -import org.eclipse.jetty.websocket.api.extensions.Frame; |
30 | 17 | import org.eclipse.jetty.websocket.client.WebSocketClient; |
31 | 18 |
|
| 19 | +import java.io.IOException; |
| 20 | +import java.text.SimpleDateFormat; |
| 21 | +import java.util.Date; |
| 22 | +import java.util.Deque; |
| 23 | +import java.util.concurrent.ConcurrentLinkedDeque; |
| 24 | +import java.util.concurrent.CountDownLatch; |
| 25 | +import java.util.concurrent.TimeUnit; |
| 26 | +import java.util.concurrent.atomic.AtomicInteger; |
| 27 | +import java.util.regex.Pattern; |
| 28 | + |
32 | 29 | /** |
33 | | - * |
34 | 30 | * @author Maciej Zaleski |
35 | 31 | */ |
36 | | -@WebSocket(maxTextMessageSize = 256 * 1024 * 1024) |
| 32 | +@WebSocket(batchMode = BatchMode.OFF, maxTextMessageSize = 256 * 1024 * 1024) |
37 | 33 | public class ServiceSocket { |
38 | 34 |
|
39 | 35 | private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); |
@@ -159,7 +155,7 @@ public Session getSession() { |
159 | 155 | } |
160 | 156 |
|
161 | 157 | public void sendMessage(String message) throws IOException { |
162 | | - session.getRemote().sendStringByFuture(message); |
| 158 | + session.getRemote().sendString(message); |
163 | 159 | } |
164 | 160 |
|
165 | 161 | public void close() { |
|
0 commit comments