@Test public void passThrough(){ KeyBasedQuery result = uut.transform(new KeyBasedQuery("store", "key serde", "key".getBytes(), "value serde")); assertThat(result.getStoreName(), is(equalTo("store"))); assertThat(result.getKeySerde(), is(equalTo("key serde"))); assertThat(new String(result.getKey()), is(equalTo("key"))); assertThat(result.getValueSerde(), is(equalTo("value serde"))); }
@Override public T transform(T object) { return object; }
KiqrCodec implements MessageCodec<T, T> { @Override public T transform(T object) { return object; } }
KiqrCodec implements MessageCodec<T, T> { @Override public T transform(T object) { return object; } KiqrCodec(Class<T> clazz); }
KiqrCodec implements MessageCodec<T, T> { @Override public T transform(T object) { return object; } KiqrCodec(Class<T> clazz); @Override void encodeToWire(Buffer buffer, T object); @Override T decodeFromWire(int pos, Buffer buffer); @Override T transform(T object); @Override String name(); @Override byte systemCodecID(); }
KiqrCodec implements MessageCodec<T, T> { @Override public T transform(T object) { return object; } KiqrCodec(Class<T> clazz); @Override void encodeToWire(Buffer buffer, T object); @Override T decodeFromWire(int pos, Buffer buffer); @Override T transform(T object); @Override String name(); @Override byte systemCodecID();  }