Class TrackerClient

src/main/java/org/traccar/TrackerClient.java:33–126

import java.util.concurrent.TimeUnit;

public abstract class TrackerClient implements TrackerConnector {

    private final boolean secure;
    private final long interval;

    private final Bootstrap bootstrap;

    private final int port;
    private final String address;
    private final String[] devices;

    private final ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    @Override
    public boolean isDatagram() {
        return false;
    }

    @Override
    public boolean isSecure() {
        return secure;
    }

    public TrackerClient(Config config, String protocol) {
        secure = config.getBoolean(Keys.PROTOCOL_SSL.withPrefix(protocol));
        interval = config.getLong(Keys.PROTOCOL_INTERVAL.withPrefix(protocol));
        address = config.getString(Keys.PROTOCOL_ADDRESS.withPrefix(protocol));
        port = config.getInteger(Keys.PROTOCOL_PORT.withPrefix(protocol), secure ? 443 : 80);
        devices = config.getString(Keys.PROTOCOL_DEVICES.withPrefix(protocol)).split("[, ]");

        BasePipelineFactory pipelineFactory = new BasePipelineFactory(this, config, protocol) {
            @Override
            protected void addTransportHandlers(PipelineBuilder pipeline) {
                try {
                    if (isSecure()) {
                        SSLEngine engine = SSLContext.getDefault().createSSLEngine();
                        engine.setUseClientMode(true);
                        pipeline.addLast(new SslHandler(engine));
                    }
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }

            @Override
            protected void addProtocolHandlers(PipelineBuilder pipeline) {
                try {
                    TrackerClient.this.addProtocolHandlers(pipeline, config);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        };

        var eventLoopGroupFactory = Main.getInjector().getInstance(EventLoopGroupFactory.class);
        bootstrap = new Bootstrap()
                .group(eventLoopGroupFactory.getWorkerGroup())
                .channel(NioSocketChannel.class)