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  {
        if (.getHostname() != null) {
            InetAddress inetAddress = InetAddress.getByName(.getHostname());
            int backlog = .getBacklog() == null ? 2 : .getBacklog();
            .info("Esper socket adapter accepting connections on port " + .getPort() + " and host '" + .getHostname() + "' backlog " + backlog + " for socket named '" + serviceName + "'");
             = new ServerSocket(.getPort(), backloginetAddress);
        }
        else {
            if (.getBacklog() != null) {
                .info("Esper socket adapter accepting connections on port " + .getPort() + " backlog " + .getBacklog() + " for socket named '" + serviceName + "'");
                 = new ServerSocket(.getPort(), .getBacklog());
            }
            else {
                .info("Esper socket adapter accepting connections on port " + .getPort() + " for socket named '" + serviceName + "'");
                 = new ServerSocket(.getPort());
            }
        }
         = new EsperSocketServiceRunnable(this.getServiceName(), this.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);
        }        
    }
    public int getPort() {
        return .getPort();
    }
New to GrepCode? Check out our FAQ X