### Question:
MySQLConnector { public synchronized InternalResultSet executeQuery(final String queryString) { responseCallback = new DefaultPromise<>(eventLoopGroup.next()); QueryCommandPacket queryCommandPacket = new QueryCommandPacket(); queryCommandPacket.setQueryString(queryString); channel.writeAndFlush(queryCommandPacket); return waitExpectedResponse(InternalResultSet.class); }  synchronized void connect(); synchronized boolean execute(final String queryString); synchronized int executeUpdate(final String queryString); synchronized InternalResultSet executeQuery(final String queryString); synchronized void subscribe(final String binlogFileName, final long binlogPosition); synchronized AbstractBinlogEvent poll();  }### Answer:
@Test public void assertExecuteQuery() throws NoSuchFieldException, IllegalAccessException { InternalResultSet expected = new InternalResultSet(null); mockChannelResponse(expected); ReflectionUtil.setFieldValueToClass(mySQLConnector, "channel", channel); assertThat(mySQLConnector.executeQuery(""), is(expected)); verify(channel).writeAndFlush(ArgumentMatchers.any(QueryCommandPacket.class)); }