### Question:
SnowdropAmqpMessage implements AmqpMessage { @Override public DataBuffer bodyAsBinary() { return dataBufferFactory.wrap(delegate.bodyAsBinary().getBytes()); } SnowdropAmqpMessage(io.vertx.amqp.AmqpMessage delegate); @Override boolean isDurable(); @Override boolean isFirstAcquirer(); @Override int priority(); @Override int deliveryCount(); @Override long ttl(); @Override String id(); @Override String address(); @Override String replyTo(); @Override String correlationId(); @Override boolean isBodyNull(); @Override boolean bodyAsBoolean(); @Override byte bodyAsByte(); @Override short bodyAsShort(); @Override int bodyAsInteger(); @Override long bodyAsLong(); @Override float bodyAsFloat(); @Override double bodyAsDouble(); @Override char bodyAsChar(); @Override Instant bodyAsTimestamp(); @Override UUID bodyAsUUID(); @Override DataBuffer bodyAsBinary(); @Override String bodyAsString(); @Override String bodyAsSymbol(); @Override List<T> bodyAsList(); @Override Map<K, V> bodyAsMap(); @Override JsonObject bodyAsJsonObject(); @Override JsonArray bodyAsJsonArray(); @Override String subject(); @Override String contentType(); @Override String contentEncoding(); @Override long expiryTime(); @Override long creationTime(); @Override String groupId(); @Override String replyToGroupId(); @Override long groupSequence(); @Override io.vertx.amqp.AmqpMessage toVertxAmqpMessage();  }### Answer:
@Test public void shouldGetBodyAsDataBuffer() { Buffer originalBuffer = Buffer.buffer("test".getBytes()); DataBuffer expectedBuffer = dataBufferFactory.wrap("test".getBytes()); given(mockDelegate.bodyAsBinary()).willReturn(originalBuffer); assertThat(new SnowdropAmqpMessage(mockDelegate).bodyAsBinary()).isEqualTo(expectedBuffer); }