Method initializeInternal

lib/java/src/main/java/com/dianping/cat/Cat.java:303–331

()

    }

    private static void initializeInternal() {
        validate();

        if (isEnabled()) {
            try {
                if (!init) {
                    synchronized (instance) {
                        if (!init) {
                            producer = DefaultMessageProducer.getInstance();
                            manager = DefaultMessageManager.getInstance();

                            StatusUpdateTask heartbeatTask = new StatusUpdateTask();
                            TcpSocketSender messageSender = TcpSocketSender.getInstance();

                            Threads.forGroup("cat").start(heartbeatTask);
                            Threads.forGroup("cat").start(messageSender);
                            Threads.forGroup("cat").start(new LocalAggregator.DataUploader());

                            CatLogger.getInstance().info("Cat is lazy initialized!");
                            init = true;
                        }
                    }
                }
            } catch (Exception e) {
                errorHandler(e);
                disable();
            }
        }
    }

    private static void initializeInternal(ClientConfig config) {
        if (isEnabled()) {