From e4410bd1c78aca7e05894e8822306b152ee70f78 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Thu, 18 Jan 2007 23:21:39 +0000 Subject: fixed 2 compilation erros git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@497633 13f79535-47bb-0310-9956-ffa450edef68 --- java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 2 +- .../src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'java/client/src') diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 86e4df9e74..fdd347fbc8 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -221,7 +221,7 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi private void dispatchMessage(UnprocessedMessage message) { - if (message.content != null) + if (message.contents != null) { final BasicMessageConsumer consumer = (BasicMessageConsumer) _consumers.get(message.contentHeader.getDestination()); diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java index af6349a164..47213af55c 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java @@ -523,7 +523,7 @@ public class BasicMessageConsumer extends Closeable implements MessageConsumer AbstractJMSMessage jmsMessage = _messageFactory.createMessage(messageFrame.deliveryTag, false, messageFrame.contentHeader, - messageFrame.content); + messageFrame.contents); _logger.debug("Message is of type: " + jmsMessage.getClass().getName()); jmsMessage.setConsumer(this); -- cgit v1.2.1