Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.espertech.esperio.socket.core;
 
 
public class EsperSocketService {
    private static Log log = LogFactory.getLog(EsperSocketService.class);
    private final String serviceName;
    private final SocketConfig serviceConfig;
    private ServerSocket serverSocket;
    private Thread socketThread;
    public EsperSocketService(String serviceNameSocketConfig serviceConfig) {
        this. = serviceName;
        this. = serviceConfig;
    }
    public String getServiceName() {
        return ;
    }
    public void start(String serviceNameEPServiceProviderSPI engineSPIthrows IOException  {
        .info("Esper socket adapter accepting connections on port " + .getPort() + " for socket named '" + serviceName + "'");
         = new ServerSocket(.getPort());
         = new EsperSocketServiceRunnable(this.getServiceName(), this..getDataType(), engineSPI);
         = new Thread();
        .setDaemon(true);
        .start();
    }
    public void destroy() {
        .info("Closing existing workers for service '" + this.getServiceName() + "'");
        .destroy();
        .info("Closing server socket for service '" + this.getServiceName() + "' and port " + .getPort());
        try {
            .close();
        } catch (IOException e) {
            .debug("Error closing server socket: " + e.getMessage(), e);
        }
        .info("Stopping socket thread for service '" + this.getServiceName() + "'");
        .interrupt();
        try {
            .join(10000);
        }
        catch (InterruptedException e) {
            .debug("Interrupted"e);
        }        
    }
New to GrepCode? Check out our FAQ X