@Named
public class BotBean {
    public String respond(String msg) { ... }
}

@ServerEndpoint(
   value = "/websocketbot",
   decoders = { MessageDecoder.class },
   encoders = { JoinMessageEncoder.class, ChatMessageEncoder.class,
                InfoMessageEncoder.class, UsersMessageEncoder.class }
)
/* Один объект BotEndpoint для каждого подключения */
public class BotEndpoint {
   private static final Logger logger = Logger.getLogger("BotEndpoint");
   /* функциональность бота */
   @Inject private BotBean botbean;
   /* Executor service для асинхронной обработки */
   @Resource(name="comp/DefaultManagedExecutorService")
   private ManagedExecutorService mes;

   @OnOpen
   public void openConnection(Session session) {
       logger.log(Level.INFO, "Connection opened.");
   }
   ...
}

@OnMessage
public void message(Session session, Message msg) {
   logger.log(Level.INFO, "Received: {0}", msg.toString());

   if (msg instanceof JoinMessage) {
      /* Добавление нового пользователя и уведомление всех */
      JoinMessage jmsg = (JoinMessage) msg;
      session.getUserProperties().put("name", jmsg.getName());
      session.getUserProperties().put("active", true);
      logger.log(Level.INFO, "Received: {0}", jmsg.toString());
      sendAll(session, new InfoMessage(jmsg.getName() +
              " has joined the chat"));
      sendAll(session, new ChatMessage("Duke", jmsg.getName(),
              "Hi there!!"));
      sendAll(session, new UsersMessage(this.getUserList(session)));

   } else if (msg instanceof ChatMessage) {
      /* Отправка сообщения всем */
      ChatMessage cmsg = (ChatMessage) msg;
      logger.log(Level.INFO, "Received: {0}", cmsg.toString());
      sendAll(session, cmsg);
      if (cmsg.getTarget().compareTo("Duke") == 0) {
         /* Ответ бота на сообщение */
         mes.submit(new Runnable() {
            @Override
            public void run() {
               String resp = botbean.respond(cmsg.getMessage());
               sendAll(session, new ChatMessage("Duke",
                       cmsg.getName(), resp));
            }
         });
      }
   }
}

public class ChatMessage extends Message {
    private String name;
    private String target;
    private String message;
    /* ... Конструктор, геттеры и сеттеры ... */
}

/* Кодировать сообщение ChatMessage как JSON.
 * Например, (new ChatMessage("Peter","Duke","How are you?"))
 * будет преобразовано к виду:
 * {"type":"chat","target":"Duke","message":"How are you?"}
 */
public class ChatMessageEncoder implements Encoder.Text<ChatMessage> {
   @Override
   public void init(EndpointConfig ec) { }
   @Override
   public void destroy() { }
   @Override
   public String encode(ChatMessage chatMessage) throws EncodeException {
      // Чтение свойств chatMessage и запись текста JSON...
   }
}

/* Декодировать сообщение JSON в JoinMessage или ChatMessage.
 * Например, входящее сообщение
 * {"type":"chat","name":"Peter","target":"Duke","message":"How are you?"}
 * будет преобразовано к (new ChatMessage("Peter", "Duke", "How are you?"))
 */
public class MessageDecoder implements Decoder.Text<Message> {
    /* Сохранение данных из JSON в отображение в виде пар ключ-значение */
    private Map<String,String> messageMap;

    @Override
    public void init(EndpointConfig ec) { }
    @Override
    public void destroy() { }

    /* Создание нового объекта Message, если это возможно */
    @Override
    public Message decode(String string) throws DecodeException {
       Message msg = null;
       if (willDecode(string)) {
          switch (messageMap.get("type")) {
             case "join":
                msg = new JoinMessage(messageMap.get("name"));
                break;
             case "chat":
                msg = new ChatMessage(messageMap.get("name"),
                                      messageMap.get("target"),
                                      messageMap.get("message"));
          }
       } else {
          throw new DecodeException(string, "[Message] Can't decode.");
       }
       return msg;
   }

   /* Преобразование сообщения JSON в отображение и проверка,
    * что присутствуют все необходимые поля. */
   @Override
   public boolean willDecode(String string) {
      // Конвертация данных их строки в отображение ключ-значение...
      // Проверка наличия всех необходимых для этого типа сообщения полей...
   }
}