18
18
19
19
import java .util .function .Function ;
20
20
21
- import org .reactivestreams .Publisher ;
22
-
23
21
import org .springframework .expression .Expression ;
24
22
import org .springframework .integration .dsl .MessageHandlerSpec ;
25
23
import org .springframework .integration .expression .FunctionExpression ;
26
24
import org .springframework .integration .expression .ValueExpression ;
27
25
import org .springframework .integration .rsocket .ClientRSocketConnector ;
28
26
import org .springframework .integration .rsocket .outbound .RSocketOutboundGateway ;
29
27
import org .springframework .messaging .Message ;
30
- import org .springframework .messaging .rsocket .RSocketRequester ;
31
- import org .springframework .messaging .rsocket .RSocketRequesterMethodArgumentResolver ;
32
28
33
29
/**
34
30
* The {@link MessageHandlerSpec} implementation for the {@link RSocketOutboundGateway}.
@@ -46,8 +42,6 @@ public class RSocketOutboundGatewaySpec extends MessageHandlerSpec<RSocketOutbou
46
42
/**
47
43
* Configure a {@link ClientRSocketConnector} for client side requests based on the connection
48
44
* provided by the {@link ClientRSocketConnector#getRSocketRequester()}.
49
- * In case of server side, an {@link RSocketRequester} must be provided in the
50
- * {@link RSocketRequesterMethodArgumentResolver#RSOCKET_REQUESTER_HEADER} header of request message.
51
45
* @param clientRSocketConnector the {@link ClientRSocketConnector} to use.
52
46
* @return the spec
53
47
* @see RSocketOutboundGateway#setClientRSocketConnector(ClientRSocketConnector)
@@ -103,8 +97,8 @@ public RSocketOutboundGatewaySpec command(Expression commandExpression) {
103
97
}
104
98
105
99
/**
106
- * Configure a type for a request {@link Publisher} elements.
107
- * @param publisherElementType the type of the request {@link Publisher} elements.
100
+ * Configure a type for a request {@link org.reactivestreams. Publisher} elements.
101
+ * @param publisherElementType the type of the request {@link org.reactivestreams. Publisher} elements.
108
102
* @return the spec
109
103
* @see RSocketOutboundGateway#setPublisherElementType(Class)
110
104
*/
@@ -113,10 +107,10 @@ public RSocketOutboundGatewaySpec publisherElementType(Class<?> publisherElement
113
107
}
114
108
115
109
/**
116
- * Configure a {@code Function} to evaluate a request {@link Publisher} elements type at runtime against
117
- * a request message.
110
+ * Configure a {@code Function} to evaluate a request {@link org.reactivestreams. Publisher}
111
+ * elements type at runtime against a request message.
118
112
* @param publisherElementTypeFunction the {@code Function} to evaluate a type for the request
119
- * {@link Publisher} elements.
113
+ * {@link org.reactivestreams. Publisher} elements.
120
114
* @param <P> the expected request message payload type.
121
115
* @return the spec
122
116
* @see RSocketOutboundGateway#setPublisherElementTypeExpression(Expression)
@@ -126,10 +120,10 @@ public <P> RSocketOutboundGatewaySpec publisherElementType(Function<Message<P>,
126
120
}
127
121
128
122
/**
129
- * Configure a SpEL expression to evaluate a request {@link Publisher} elements type at runtime against
130
- * a request message.
123
+ * Configure a SpEL expression to evaluate a request {@link org.reactivestreams. Publisher}
124
+ * elements type at runtime against a request message.
131
125
* @param publisherElementTypeExpression the expression to evaluate a type for the request
132
- * {@link Publisher} elements.
126
+ * {@link org.reactivestreams. Publisher} elements.
133
127
* @return the spec
134
128
* @see RSocketOutboundGateway#setPublisherElementTypeExpression(Expression)
135
129
*/
@@ -138,10 +132,10 @@ public RSocketOutboundGatewaySpec publisherElementType(String publisherElementTy
138
132
}
139
133
140
134
/**
141
- * Configure a SpEL expression to evaluate a request {@link Publisher} elements type at runtime against
142
- * a request message.
135
+ * Configure a SpEL expression to evaluate a request {@link org.reactivestreams. Publisher}
136
+ * elements type at runtime against a request message.
143
137
* @param publisherElementTypeExpression the expression to evaluate a type for the request
144
- * {@link Publisher} elements.
138
+ * {@link org.reactivestreams. Publisher} elements.
145
139
* @return the spec
146
140
* @see RSocketOutboundGateway#setPublisherElementTypeExpression(Expression)
147
141
*/
0 commit comments