@Test
public void shouldStoreActivityLogIfEnabled() {

  Frame request1 = FrameUtils.wrapRequest(new Query("use myks"));
  QueryOptions options =
      new QueryOptions(
          ProtocolConstants.ConsistencyLevel.QUORUM,
          Collections.emptyList(),
          Collections.emptyMap(),
          false,
          -1,
          null,
          ProtocolConstants.ConsistencyLevel.SERIAL,
          Long.MIN_VALUE,
          null);
  Query query2 = new Query("select * from table1", options);
  Frame request2 = FrameUtils.wrapRequest(query2);
  loggedChannel.writeInbound(request1);
  loggedChannel.readOutbound();
  loggedChannel.writeInbound(request2);
  loggedChannel.readOutbound();
  List<QueryLog> logs = loggedNode.getLogs().getQueryLogs();
  assertThat(logs.size()).isEqualTo(2);
  QueryLog log1 = logs.get(0);
  assertThat(log1.getQuery()).isEqualTo("use myks");
  assertThat(log1.getConsistency()).isEqualTo(ConsistencyLevel.ONE);
  QueryLog log2 = logs.get(1);
  assertThat(log2.getQuery()).isEqualTo("select * from table1");
  assertThat(log2.getConsistency()).isEqualTo(ConsistencyLevel.QUORUM);
}