GooglePubsubLiteConsumer(GooglePubsubLiteEndpoint endpoint, Processor processor) {
        super(endpoint, processor);
        this.endpoint = endpoint;
        this.processor = processor;
        this.subscribers = Collections.synchronizedList(new LinkedList<>());
        String loggerId = endpoint.getLoggerId();

        if (Strings.isNullOrEmpty(loggerId)) {
            loggerId = this.getClass().getName();
        }

        localLog = LoggerFactory.getLogger(loggerId);
    }
@Test
    public void testGooglePubsubLiteConsumer() {
        when(endpoint.getCamelContext()).thenReturn(context);
        GooglePubsubLiteConsumer consumer = new GooglePubsubLiteConsumer(endpoint, processor);
        assertNotNull(consumer);
    }