1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.eclipse.jetty.websocket.jsr356.annotations;
20
21 import java.lang.reflect.Method;
22 import java.nio.ByteBuffer;
23
24 import javax.websocket.DecodeException;
25 import javax.websocket.OnMessage;
26 import javax.websocket.PongMessage;
27
28 import org.eclipse.jetty.websocket.jsr356.JsrPongMessage;
29 import org.eclipse.jetty.websocket.jsr356.JsrSession;
30 import org.eclipse.jetty.websocket.jsr356.annotations.Param.Role;
31
32
33
34
35 public class OnMessagePongCallable extends OnMessageCallable
36 {
37 public OnMessagePongCallable(Class<?> pojo, Method method)
38 {
39 super(pojo,method);
40 }
41
42
43
44
45 public OnMessagePongCallable(OnMessageCallable copy)
46 {
47 super(copy);
48 }
49
50 public Object call(Object endpoint, ByteBuffer buf) throws DecodeException
51 {
52 super.args[idxMessageObject] = new JsrPongMessage(buf);
53 return super.call(endpoint,super.args);
54 }
55
56 @Override
57 public void init(JsrSession session)
58 {
59 idxMessageObject = findIndexForRole(Role.MESSAGE_PONG);
60 assertRoleRequired(idxMessageObject,"Pong Message Object");
61 super.init(session);
62 }
63 }