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... #1731

Merged
merged 1 commit into from

2 participants

@jbertram
Owner

...hrows RuntimeException

@clebertsuconic clebertsuconic merged commit 62f4810 into hornetq:master

1 check passed

Details default Merged build finished.
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.