You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by KRISHNAS <kr...@hotmail.com> on 2010/06/01 20:39:20 UTC
Re: Dead letter queue not being created
Gary
5.4-SNAPSHOT has the same issue. Looks like addMessage method of
JDBCMessageStore class has changed in 5.3.1. The following code is added to
it, seems it is stopping to persist in the DB.
public void addMessage(ConnectionContext context, Message message)
throws IOException {
MessageId messageId = message.getMessageId();
if (audit != null && audit.isDuplicate(message)) {
if (LOG.isDebugEnabled()) {
LOG.debug(destination.getPhysicalName()
+ " ignoring duplicated (add) message, already stored: "
+ messageId);
}
return;
}
long sequenceId = persistenceAdapter.getNextSequenceId();
....
Thanks for your support.
Krishna.
--
View this message in context: http://old.nabble.com/Dead-letter-queue-not-being-created-tp28576004p28745801.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Dead letter queue not being created
Posted by KRISHNAS <kr...@hotmail.com>.
Jira created.
https://issues.apache.org/activemq/browse/AMQ-2756
https://issues.apache.org/activemq/browse/AMQ-2756
KRISHNAS wrote:
>
> Gary
>
> 5.4-SNAPSHOT has the same issue. Looks like addMessage method of
> JDBCMessageStore class has changed in 5.3.1. The following code is added
> to it, seems it is stopping to persist in the DB.
>
> public void addMessage(ConnectionContext context, Message message)
> throws IOException {
>
> MessageId messageId = message.getMessageId();
> if (audit != null && audit.isDuplicate(message)) {
> if (LOG.isDebugEnabled()) {
> LOG.debug(destination.getPhysicalName()
> + " ignoring duplicated (add) message, already stored:
> "
> + messageId);
> }
> return;
> }
>
> long sequenceId = persistenceAdapter.getNextSequenceId();
> ....
>
> Thanks for your support.
> Krishna.
>
--
View this message in context: http://old.nabble.com/Dead-letter-queue-not-being-created-tp28576004p28747773.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.