just a minor improvement over the previous commit (758293)

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@758294 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2009-03-25 15:07:15 +00:00
parent 65aef36600
commit 27ea85e15a
1 changed files with 1 additions and 2 deletions

View File

@ -189,8 +189,7 @@ public class JournalEndpoint extends DefaultEndpoint {
public void process(Exchange exchange) throws Exception {
incrementReference();
try {
ByteSequence body = null;
body = exchange.getIn().getBody(ByteSequence.class);
ByteSequence body = exchange.getIn().getBody(ByteSequence.class);
if (body == null) {
byte[] bytes = exchange.getIn().getBody(byte[].class);
if (bytes != null) {