Return-Path: 
 <dev-return-37277-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
X-Original-To: apmail-activemq-dev-archive@www.apache.org
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 1F436DBD1
	for <apmail-activemq-dev-archive@www.apache.org>;
 Wed, 13 Mar 2013 18:00:17 +0000 (UTC)
Received: (qmail 67379 invoked by uid 500); 13 Mar 2013 18:00:16 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 67330 invoked by uid 500); 13 Mar 2013 18:00:16 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 67311 invoked by uid 99); 13 Mar 2013 18:00:16 -0000
Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Mar 2013 18:00:16 +0000
Date: Wed, 13 Mar 2013 18:00:16 +0000 (UTC)
From: "Timothy Bish (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: <JIRA.12632372.1360848211091.435092.1363197616585@arcas>
In-Reply-To: <JIRA.12632372.1360848211091@arcas>
References: <JIRA.12632372.1360848211091@arcas>
Subject: [jira] [Closed] (AMQ-4316) Problem with duplicate message detection
 using ObjectMessage with equal object
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394


     [ https://issues.apache.org/jira/browse/AMQ-4316?page=3Dcom.atlassian.=
jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish closed AMQ-4316.
-----------------------------

    Resolution: Incomplete

No test case or supporting information supplied.
               =20
> Problem with duplicate message detection using ObjectMessage with equal o=
bject
> -------------------------------------------------------------------------=
-----
>
>                 Key: AMQ-4316
>                 URL: https://issues.apache.org/jira/browse/AMQ-4316
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker, Message Store
>    Affects Versions: 5.8.0
>         Environment: Activemq 5.8.0, Kahadb store.
>            Reporter: Pether S=C3=B6rling
>             Fix For: AGING_TO_DIE
>
>
> When sending any ObjectMessage that contain an equal object to was been s=
ent before I get from KahaDBStore : Duplicate message add attempt rejected.
> So even if the messageId and commandId is different the message is still =
detected as a duplicate and ignored.
> A simple test would be to create two objectmessages with "session.createO=
bjectMessage("ANY OBJECT THAT is Equal")" and send to a queue.=20
> Our code worked with version 5.7.0 and tested amq-store as well as KahaDb=
store.=20
> -- activemq config--
> <?xml version=3D"1.0" encoding=3D"UTF-8"?>
> <beans xmlns=3D"http://www.springframework.org/schema/beans"
> =09xmlns:xsi=3D"http://www.w3.org/2001/XMLSchema-instance" xmlns:aop=3D"h=
ttp://www.springframework.org/schema/aop"
> =09xmlns:context=3D"http://www.springframework.org/schema/context"
> =09xmlns:amq=3D"http://activemq.apache.org/schema/core" xmlns:jms=3D"http=
://www.springframework.org/schema/jms"
> =09xmlns:tx=3D"http://www.springframework.org/schema/tx"
> =09xsi:schemaLocation=3D"http://www.springframework.org/schema/beans http=
://www.springframework.org/schema/beans/spring-beans-3.0.xsd
> =09=09http://www.springframework.org/schema/tx http://www.springframework=
.org/schema/tx/spring-tx-3.0.xsd
> =09=09http://www.springframework.org/schema/context http://www.springfram=
ework.org/schema/context/spring-context-3.0.xsd
> =09=09http://www.springframework.org/schema/aop http://www.springframewor=
k.org/schema/aop/spring-aop-3.0.xsd
> =09=09http://activemq.apache.org/schema/core http://activemq.apache.org/s=
chema/core/activemq-core-5.4.1.xsd
> =09=09http://www.springframework.org/schema/jms  http://www.springframewo=
rk.org/schema/jms/spring-jms-3.0.xsd">
> =09<!-- lets create an embedded ActiveMQ Broker -->
> =09<amq:broker brokerName=3D"broker" id=3D"broker" useJmx=3D"true" useShu=
tdownHook=3D"false"
> =09=09persistent=3D"true" enableStatistics=3D"true">
> =09=09
> =09=09<!-- add network http://activemq.apache.org/networks-of-brokers.htm=
l -->
> =09=09
> =09=09 <amq:persistenceAdapter>
>       =09=09<amq:kahaDB directory=3D"activemq-data/broker/KahaDB" journal=
MaxFileLength=3D"32mb"/>=20
>     =09 </amq:persistenceAdapter>
> =09=09
> =09=09<amq:networkConnectors>
>       =09=09<amq:networkConnector uri=3D"${server.activemq.networkconnect=
ors.uri}" />
>     =09</amq:networkConnectors>
> =09=09
> =09=09<amq:destinationPolicy>
> =09=09=09<amq:policyMap>
> =09=09=09=09<amq:policyEntries>
> =09=09=09=09=09<amq:policyEntry queue=3D">" optimizedDispatch=3D"true"
> =09=09=09=09=09=09lazyDispatch=3D"false" producerFlowControl=3D"false" me=
moryLimit=3D"128 mb"
> =09=09=09=09=09=09strictOrderDispatch=3D"true">
> =09=09=09=09=09=09<amq:dispatchPolicy>
> =09=09=09=09=09=09=09<amq:strictOrderDispatchPolicy />
> =09=09=09=09=09=09</amq:dispatchPolicy>
> =09=09=09=09=09=09<amq:messageGroupMapFactory>
> =09=09=09=09=09=09=09<amq:simpleMessageGroupMapFactory />
> =09=09=09=09=09=09</amq:messageGroupMapFactory>
> =09=09=09=09=09=09<amq:subscriptionRecoveryPolicy>
> =09=09=09=09=09=09=09<amq:timedSubscriptionRecoveryPolicy
> =09=09=09=09=09=09=09=09recoverDuration=3D"360000" />
> =09=09=09=09=09=09</amq:subscriptionRecoveryPolicy>
> =09=09=09=09=09</amq:policyEntry>
> =09=09=09=09</amq:policyEntries>
> =09=09=09</amq:policyMap>
> =09=09</amq:destinationPolicy>
>      <amq:systemUsage>
>        <amq:systemUsage sendFailIfNoSpace=3D"true" >
>          <amq:memoryUsage>
>            <amq:memoryUsage limit=3D"256mb" />
>          </amq:memoryUsage>
>          <amq:storeUsage>
>            <amq:storeUsage limit=3D"0" />
>          </amq:storeUsage>      =20
>          <amq:tempUsage>
>            <amq:tempUsage limit=3D"4096mb" />
>          </amq:tempUsage>
>        </amq:systemUsage>
>      </amq:systemUsage>
>     =20
> =09=09<amq:transportConnectors>
> =09=09=09<!--<amq:transportConnector uri=3D"tcp://localhost:0?jms.prefetc=
hPolicy.all=3D50"
> =09=09=09=09/> -->
> =09=09=09<amq:transportConnector uri=3D"vm://localhost:0" />
> =09=09=09<amq:transportConnector name=3D"gwt-ajax" uri=3D"tcp://0.0.0.0:$=
{jms.port}"/>
> =09=09</amq:transportConnectors>
> =09</amq:broker>
> =09<amq:xaConnectionFactory id=3D"jmsFactory"
> =09=09brokerURL=3D"${server.activemq.jmsfactory.brokerURL}" />
> =09<!-- <bean id=3D"connectionFactory" class=3D"org.springframework.jms.c=
onnection.CachingConnectionFactory"
> =09=09depends-on=3D"broker"> <constructor-arg ref=3D"jmsFactory" /> <prop=
erty name=3D"sessionCacheSize"
> =09=09value=3D"100" /> </bean> -->
> =09<bean id=3D"connectionFactory" depends-on=3D"broker"
> =09=09class=3D"com.atomikos.jms.AtomikosConnectionFactoryBean" init-metho=
d=3D"init"
> =09=09destroy-method=3D"close">
> =09=09<property name=3D"uniqueResourceName" value=3D"borgenBackOfficeJmsC=
onnectionFactory" />
> =09=09<property name=3D"xaConnectionFactory" ref=3D"jmsFactory" />
> =09=09<property name=3D"maxPoolSize" value=3D"96" />
> =09=09<property name=3D"minPoolSize" value=3D"4" />
> =09</bean>
> =09<bean id=3D"lifecycleProcessor"
> =09=09class=3D"org.springframework.context.support.DefaultLifecycleProces=
sor">
> =09=09<!-- timeout value in milliseconds -->
> =09=09<property name=3D"timeoutPerShutdownPhase" value=3D"1500" />
> =09</bean>
> </beans>
> --

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrato=
rs
For more information on JIRA, see: http://www.atlassian.com/software/jira