10BC0 Merge pull request #58 from rabbitmq/rabbitmq-java-client-30 · egolin/rabbitmq-java-client@f6e1f23 · GitHub
[go: up one dir, main page]

Skip to content

Commit f6e1f23

Browse files
committed
Merge pull request rabbitmq#58 from rabbitmq/rabbitmq-java-client-30
Make it clearer that publishes can block when an alarm is in effect
2 parents 5706325 + bdc4533 commit f6e1f23

File tree

1 file changed

+24
-3
lines changed

1 file changed

+24
-3
lines changed

src/com/rabbitmq/client/Channel.java

Lines changed: 24 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -245,8 +245,16 @@ public interface Channel extends ShutdownNotifier {
245245
void basicQos(int prefetchCount) throws IOException;
246246

247247
/**
248-
* Publish a message
248+
* Publish a message.
249+
*
250+
* Publishing to a non-existent exchange will result in a channel-level
251+
* protocol exception, which closes the channel.
252+
*
253+
* Invocations of <code>Channel#basicPublish</code> will eventually block if a
254+
* <a href="http://www.rabbitmq.com/alarms.html">resource-driven alarm</a> is in effect.
255+
*
249256
* @see com.rabbitmq.client.AMQP.Basic.Publish
257+
* @see <a href="http://www.rabbitmq.com/alarms.html">Resource-driven alarms</a>.
250258
* @param exchange the exchange to publish the message to
251259
* @param routingKey the routing key
252260
* @param props other properties for the message - routing headers etc
@@ -256,8 +264,13 @@ public interface Channel extends ShutdownNotifier {
256264
void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException;
257265

258266
/**
259-
* Publish a message
267+
* Publish a message.
268+
*
269+
* Invocations of <code>Channel#basicPublish</code> will eventually block if a
270+
* <a href="http://www.rabbitmq.com/alarms.html">resource-driven alarm</a> is in effect.
271+
*
260272
* @see com.rabbitmq.client.AMQP.Basic.Publish
273+
* @see <a href="http://www.rabbitmq.com/alarms.html">Resource-driven alarms</a>.
261274
* @param exchange the exchange to publish the message to
262275
* @param routingKey the routing key
263276
* @param mandatory true if the 'mandatory' flag is to be set
@@ -269,8 +282,16 @@ void basicPublish(String exchange, String routingKey, boolean mandatory, BasicPr
269282
throws IOException;
270283

271284
/**
272-
* Publish a message
285+
* Publish a message.
286+
*
287+
* Publishing to a non-existent exchange will result in a channel-level
288+
* protocol exception, which closes the channel.
289+
*
290+
* Invocations of <code>Channel#basicPublish</code> will eventually block if a
291+
* <a href="http://www.rabbitmq.com/alarms.html">resource-driven alarm</a> is in effect.
292+
*
273293
* @see com.rabbitmq.client.AMQP.Basic.Publish
294+
* @see <a href="http://www.rabbitmq.com/alarms.html">Resource-driven alarms</a>.
274295
* @param exchange the exchange to publish the message to
275296
* @param routingKey the routing key
276297
* @param mandatory true if the 'mandatory' flag is to be set

0 commit comments

Comments
 (0)
0