Author: ritchiem
Date: Thu Apr 5 02:57:33 2007
New Revision: 525786
URL: http://svn.apache.org/viewvc?view=rev&rev=525786
Log:
QPID-440 - added comments in the code relating to this bug.
Modified:
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
Modified:
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java?view=diff&rev=525786&r1=525785&r2=525786
==============================================================================
---
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
(original)
+++
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
Thu Apr 5 02:57:33 2007
@@ -196,6 +196,7 @@
}
else
{
+ _logger.error("MESSAGE LOSS: Message should be sent on a Dead
Letter Queue");
_logger.warn(msg);
}
}
Modified:
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java?view=diff&rev=525786&r1=525785&r2=525786
==============================================================================
---
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
(original)
+++
incubator/qpid/branches/M2/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
Thu Apr 5 02:57:33 2007
@@ -195,6 +195,7 @@
{
_txnBuffer.enlist(new StoreMessageOperation(_messageStore));
}
+ //fixme fail commit here ... QPID-440
try
{
_txnBuffer.commit(_storeContext);