JmsAdapter extends CommAdapter<String> { public <T> Flowable<RpcInvocation<T>> requests(Destination destination, Class<T> requestType) { requireNonNull(destination, "destination must not be null"); return rpcServer.requests(destination, requestType); } 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 subscribingToRequestsCannotBeDoneWithNullDestination() { NullPointerException npe = assertThrows(NullPointerException.class, () -> sut.requests(null, String.class)); assertThat(npe.getMessage(), containsString("destination must not be null")); }