JmsAdapter extends CommAdapter<String> { public static Builder builder() { return new Builder(); } JmsAdapter(Builder builder); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message, Map<String, Object> customHeaders); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message, Map<String, Object> customHeaders, Integer deliveryMode, Integer priority, Long timeToLive); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message, Function<T, String> transcriber); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message, Function<T, String> transcriber, Map<String, Object> customHeaders); Single<OutgoingMessageMetaData> sendMessage(Destination destination, T message, Function<T, String> transcriber, Map<String, Object> customHeaders, Integer deliveryMode, Integer priority, Long timeToLive); Single<OutgoingMessageMetaData> sendMessage(Destination destination, String message); Single<OutgoingMessageMetaData> sendMessage(Destination destination, String message, Map<String, Object> customHeaders); Flowable<String> messages(Destination destination); Flowable<T> messages(Destination destination, Class<T> messageType); Flowable<T> messages(Destination destination, Function<String, T> messageTranscriber); Flowable<RpcInvocation<T>> requests(Destination destination, Class<T> requestType); Single<RpcReply<U>> sendRequest(
            Destination destination,
            Destination replyDestination,
            T request,
            Map<String, Object> customHeaders,
            Function<String, U> replyTranscriber,
            Integer deliveryMode, Integer priority, Long timeToLive,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            Destination replyDestination,
            T message,
            Map<String, Object> customHeaders,
            Function<String, U> replyTranscriber,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Map<String, Object> customHeaders,
            Function<String, U> replyTranscriber,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Map<String, Object> customHeaders,
            Function<String, U> replyTranscriber); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Function<String, U> replyTranscriber,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Function<String, U> replyTranscriber); Single<RpcReply<U>> sendRequest(
            Destination destination,
            Destination replyDestination,
            T request,
            Map<String, Object> customHeaders,
            Class<U> replyType,
            Integer deliveryMode, Integer priority, Long timeToLive,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            Destination replyDestination,
            T message,
            Map<String, Object> customHeaders,
            Class<U> replyType,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Map<String, Object> customHeaders,
            Class<U> replyType,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Map<String, Object> customHeaders,
            Class<U> replyType); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Class<U> replyType,
            Duration timeout); Single<RpcReply<U>> sendRequest(
            Destination destination,
            T message,
            Class<U> replyType); void addDestinationListener(Consumer<Destination> destinationListener); void removeDestinationListener(Consumer<Destination> destinationListener); void shutdown(); void start(); static Builder builder();  }
@Test void instanceCannotBeCreatedWithoutConnectionFactory() { Throwable t = assertThrows(NullPointerException.class, () -> JmsAdapter.builder() .setRpcClient(null) .build()); assertThat(t.getMessage(),containsString("connectionFactory")); }