CommandClientImpl extends AbstractRequestResponseClient<BufferResult> implements CommandClient { @Override public Future<Void> sendOneWayCommand(final String deviceId, final String command, final Buffer data) { return sendOneWayCommand(deviceId, command, null, data, null); } CommandClientImpl(
            final HonoConnection connection,
            final String tenantId,
            final String replyId,
            final SendMessageSampler sampler);   CommandClientImpl(
            final HonoConnection connection,
            final String tenantId,
            final String replyId,
            final ProtonSender sender,
            final ProtonReceiver receiver,
            final SendMessageSampler sampler); @Override Future<BufferResult> sendCommand(final String deviceId, final String command, final Buffer data); @Override Future<BufferResult> sendCommand(final String deviceId, final String command, final String contentType,
            final Buffer data, final Map<String, Object> properties); @Override Future<Void> sendOneWayCommand(final String deviceId, final String command, final Buffer data); @Override Future<Void> sendOneWayCommand(
            final String deviceId,
            final String command,
            final String contentType,
            final Buffer data,
            final Map<String, Object> properties); static final Future<CommandClient> create(
            final HonoConnection con,
            final String tenantId,
            final String replyId,
            final SendMessageSampler sampler,
            final Handler<String> senderCloseHook,
            final Handler<String> receiverCloseHook);  }
@Test public void testSendOneWayCommandSetsCorrelationIdAndEmptyReplyTo() { final Map<String, Object> applicationProperties = new HashMap<>(); applicationProperties.put("appKey", "appValue"); client.sendOneWayCommand(DEVICE_ID, "doSomething", "text/plain", Buffer.buffer("payload"), applicationProperties); final ArgumentCaptor<Message> messageCaptor = ArgumentCaptor.forClass(Message.class); verify(sender).send(messageCaptor.capture(), VertxMockSupport.anyHandler()); assertThat(messageCaptor.getValue().getSubject()).isEqualTo("doSomething"); assertNotNull(messageCaptor.getValue().getMessageId()); assertThat(messageCaptor.getValue().getContentType()).isEqualTo("text/plain"); assertNull(messageCaptor.getValue().getReplyTo()); assertNotNull(messageCaptor.getValue().getApplicationProperties()); assertThat(messageCaptor.getValue().getApplicationProperties().getValue().get("appKey")).isEqualTo("appValue"); }