diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-18 23:21:39 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-01-18 23:21:39 +0000 |
| commit | e4410bd1c78aca7e05894e8822306b152ee70f78 (patch) | |
| tree | 6056ac39319d8d8b9e6ce89c06ec620713cb6e05 /java/client/src | |
| parent | 3c0e0c3bb319af15035f1c6596fd1a5c7568c293 (diff) | |
| download | qpid-python-e4410bd1c78aca7e05894e8822306b152ee70f78.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 2 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 2 |
2 files changed, 2 insertions, 2 deletions
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); |