diff options
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java index e1b399e10a..4dcd5a2e44 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java @@ -217,6 +217,14 @@ public class BasicMessageProducer_0_8 extends BasicMessageProducer AMQFrame contentHeaderFrame = ContentHeaderBody.createAMQFrame(getChannelId(), classIfForBasic, 0, contentHeaderProperties, size); + if(contentHeaderFrame.getSize() > getSession().getAMQConnection().getMaximumFrameSize()) + { + throw new JMSException("Unable to send message as the headers are too large (" + + contentHeaderFrame.getSize() + + " bytes, but the maximum negotiated frame size is " + + getSession().getAMQConnection().getMaximumFrameSize() + + ")."); + } if (getLogger().isDebugEnabled()) { getLogger().debug("Sending content header frame to " + destination); |