/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package cz.kiwi.cometd.websocket.protocol;

import java.io.IOException;
import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
import org.eclipse.jetty.websocket.WebSocket;

/**
 *
 * @author esner
 */
public class WebSocketKiwiCommandProtocol implements WebSocket.OnTextMessage {
    private static final Logger logger = Log.getLogger(WebSocketKiwiCommandProtocol.class);
    
    WebSocket.Connection _connection;
 
    public void onOpen(WebSocket.Connection connection) {
      logger.info("COMMAND: opening connection: " + connection.toString());
        
      _connection=connection;
    }
 
    public void onClose(int closeCode, String message)
    {
         logger.info("COMMAND: closing connection: " + closeCode);
         _connection = null;
    }
 
    public void onMessage(String data)
    {
       logger.info("COMMAND: message: " + data); 
    }
    
    public void sendMessage(String message) {
      if (this._connection != null) {
            try {
               _connection.sendMessage(message);
            } catch (IOException ex) {
               logger.warn(ex.getMessage());
            } 
      }
    }
}