ConnectorImpl implements Connector { public void init(Instrumentation inst, QueryReporter queryReporter, ConnectorConfiguration configuration, GlobalConfiguration globalConfiguration) { ConnectorImpl.configuration = configuration; ConnectorImpl.globalConfiguration = globalConfiguration; queryProcessorWrapper = new QueryProcessorWrapper(queryReporter, configuration); setQueryProcessorIntercepter(inst); setCassandraDaemonIntercepter(inst); }  static QueryProcessorWrapper queryProcessorWrapper(); static void cassandraSetupComplete(); void waitForSetupCompleted(); InfoProvider getInfoProvider(); void init(Instrumentation inst, QueryReporter queryReporter, ConnectorConfiguration configuration,
            GlobalConfiguration globalConfiguration);  }
@Test @SuppressWarnings("unchecked") public void invokes_wrapper_when_query_processor_process_prepared_activates() throws Exception { ConnectorConfiguration configuration = new ConnectorConfiguration(); Connector connector = new ConnectorImpl(); connector.init(instrumentation, mock(QueryReporter.class), configuration, GlobalConfiguration.getDefault()); QueryProcessorWrapper queryProcessorWrapper = mock(QueryProcessorWrapper.class); setStatic(ConnectorImpl.class.getDeclaredField("queryProcessorWrapper"), queryProcessorWrapper); QueryProcessor queryProcessor = QueryProcessor.instance; CQLStatement statement = mock(CQLStatement.class); QueryState queryState = mock(QueryState.class); QueryOptions options = mock(QueryOptions.class); queryProcessor.processPrepared(statement, queryState, options); verify(queryProcessorWrapper) .processPrepared(same(statement), same(queryState), same(options), any(Long.class), any(ResultMessage.class), any(ConcurrentLinkedHashMap.class)); }