Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP

Loading…

BZ997782 - Calling message.clearBody() on large message after failover t... #1732

Merged
merged 1 commit into from

2 participants

@jbertram
Owner

...hrows RuntimeException

@clebertsuconic clebertsuconic merged commit 6537927 into hornetq:2.4.x
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on Jul 22, 2014
  1. @jbertram
This page is out of date. Refresh to see the latest.
View
13 hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQBytesMessage.java
@@ -407,11 +407,20 @@ public void doBeforeReceive() throws HornetQException
// HornetQRAMessage overrides ----------------------------------------
@Override
- public void clearBody()
+ public void clearBody() throws JMSException
{
super.clearBody();
- getBuffer().clear();
+ try
+ {
+ getBuffer().clear();
+ }
+ catch (RuntimeException e)
+ {
+ JMSException e2 = new JMSException(e.getMessage());
+ e2.initCause(e);
+ throw e2;
+ }
}
public long getBodyLength() throws JMSException
View
2  hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQMapMessage.java
@@ -368,7 +368,7 @@ public boolean itemExists(final String name) throws JMSException
// HornetQRAMessage overrides ----------------------------------------
@Override
- public void clearBody()
+ public void clearBody() throws JMSException
{
super.clearBody();
View
2  hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQMessage.java
@@ -583,7 +583,7 @@ public void clearProperties() throws JMSException
propertiesReadOnly = false;
}
- public void clearBody()
+ public void clearBody() throws JMSException
{
readOnly = false;
}
View
2  hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQObjectMessage.java
@@ -164,7 +164,7 @@ public Serializable getObject() throws JMSException
}
@Override
- public void clearBody()
+ public void clearBody() throws JMSException
{
super.clearBody();
View
2  hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQStreamMessage.java
@@ -555,7 +555,7 @@ public void reset() throws JMSException
// HornetQRAMessage overrides ----------------------------------------
@Override
- public void clearBody()
+ public void clearBody() throws JMSException
{
super.clearBody();
View
2  hornetq-jms-client/src/main/java/org/hornetq/jms/client/HornetQTextMessage.java
@@ -114,7 +114,7 @@ public String getText()
}
@Override
- public void clearBody()
+ public void clearBody() throws JMSException
{
super.clearBody();
Something went wrong with that request. Please try again.