@@ -129,91 +129,6 @@ public RpcClient(RpcClientParams params) throws
129
129
}
130
130
}
131
131
132
- /**
133
- * Construct a new RpcClient that will communicate on the given channel, sending
134
- * requests to the given exchange with the given routing key.
135
- *
136
- * Causes the creation of a temporary private autodelete queue. The name of this queue can be specified.
137
- * @param channel the channel to use for communication
138
- * @param exchange the exchange to connect to
139
- * @param routingKey the routing key
140
- * @param replyTo the queue where the server should put the reply
141
- * @param timeout milliseconds before timing out on wait for response
142
- * @throws IOException if an error is encountered
143
- * @deprecated use {@link RpcClient#RpcClient(RpcClientParams)} instead, will be removed in 6.0.0
144
- */
145
- @ Deprecated
146
- public RpcClient (Channel channel , String exchange , String routingKey , String replyTo , int timeout ) throws
147
- IOException {
148
- this (new RpcClientParams ()
149
- .channel (channel ).exchange (exchange ).routingKey (routingKey )
150
- .replyTo (replyTo ).timeout (timeout )
151
- .useMandatory (false )
152
- );
153
- }
154
-
155
- /**
156
- * Construct a new RpcClient that will communicate on the given channel, sending
157
- * requests to the given exchange with the given routing key.
158
- *
159
- * Causes the creation of a temporary private autodelete queue.
160
- * The name of the queue can be provided (only relevant for RabbitMQ servers
161
- * that do not support <a href="https://www.rabbitmq.com/direct-reply-to.html">Direct Reply-to</a>.
162
- *
163
- * Waits forever for responses (that is, no timeout).
164
- * @param channel the channel to use for communication
165
- * @param exchange the exchange to connect to
166
- * @param routingKey the routing key
167
- * @param replyTo the queue where the server should put the reply
168
- * @throws IOException if an error is encountered
169
- * @deprecated use {@link RpcClient#RpcClient(RpcClientParams)} instead, will be removed in 6.0.0
170
- */
171
- @ Deprecated
172
- public RpcClient (Channel channel , String exchange , String routingKey , String replyTo ) throws IOException {
173
- this (channel , exchange , routingKey , replyTo , NO_TIMEOUT );
174
- }
175
-
176
- /**
177
- * Construct a new RpcClient that will communicate on the given channel, sending
178
- * requests to the given exchange with the given routing key.
179
- *
180
- * <a href="https://www.rabbitmq.com/direct-reply-to.html">Direct Reply-to</a> will be used
181
- * for response propagation.
182
- *
183
- * Waits forever for responses (that is, no timeout).
184
- * @param channel the channel to use for communication
185
- * @param exchange the exchange to connect to
186
- * @param routingKey the routing key
187
- * @throws IOException if an error is encountered
188
- * @deprecated use {@link RpcClient#RpcClient(RpcClientParams)} instead, will be removed in 6.0.0
189
- */
190
- @ Deprecated
191
- public RpcClient (Channel channel , String exchange , String routingKey ) throws IOException {
192
- this (channel , exchange , routingKey , "amq.rabbitmq.reply-to" , NO_TIMEOUT );
193
- }
194
-
195
-
196
- /**
197
- * <p>
198
- * Construct a new RpcClient that will communicate on the given channel, sending
199
- * requests to the given exchange with the given routing key.
200
- * </p>
201
- *
202
- * Causes the creation of a temporary private autodelete queue. The name of this queue will be
203
- * "amq.rabbitmq.reply-to".
204
- * @param channel the channel to use for communication
205
- * @param exchange the exchange to connect to
206
- * @param routingKey the routing key
207
- * @param timeout milliseconds before timing out on wait for response
208
- * @throws IOException if an error is encountered
209
- * @deprecated use {@link RpcClient#RpcClient(RpcClientParams)} instead, will be removed in 6.0.0
210
- */
211
- @ Deprecated
212
- public RpcClient (Channel channel , String exchange , String routingKey , int timeout ) throws IOException {
213
- this (channel , exchange , routingKey , "amq.rabbitmq.reply-to" , timeout );
214
- }
215
-
216
-
217
132
/**
218
133
* Private API - ensures the RpcClient is correctly open.
219
134
* @throws IOException if an error is encountered
0 commit comments