[ebxmlms-develop] Duplicate Elimination not working

SourceForge Headquarters 1320 Columbia Street Suite 310 San Diego, CA 92101 +1 (858) 422-6466

All,

to verify duplicate elimination i do the following 

1] send a message with utility generated message. i
also store the message id.
2] then i try sending a second message with the
messageId    generated from step [1] 

i get the following error 

12:12:09,888 ERROR [STDERR]
hk.hku.cecid.phoenix.message.handler.RequestException:

Fail to send EbxmlMessage to MessageServiceHandler:
  HTTP response code = 200
  HTTP response message = OK
12:12:09,888 ERROR [STDERR] 	at
hk.hku.cecid.phoenix.message.handler.Request.sendMessage(Request.java:1595)
12:12:09,888 ERROR [STDERR] 	at
hk.hku.cecid.phoenix.message.handler.Request.send(Request.java:1100)
12:12:09,898 ERROR [STDERR] 	at
Ping.runDuplicateElimination1(Ping.java:163)
12:12:09,898 ERROR [STDERR] 	at
Ping.doPost(Ping.java:54)
12:12:09,898 ERROR [STDERR] 	at
Ping.doGet(Ping.java:30)
12:12:09,898 ERROR [STDERR] 	at
javax.servlet.http.HttpServlet.service(HttpServlet.java:740)
12:12:09,898 ERROR [STDERR] 	at
javax.servlet.http.HttpServlet.service(HttpServlet.java:853)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:247)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:193)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:256)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:643)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:480)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:995)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:643)
12:12:09,898 ERROR [STDERR] 	at
org.jboss.web.tomcat.security.JBossSecurityMgrRealm.invoke(JBossSecurityMgrRealm.java:220)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.valves.CertificatesValve.invoke(CertificatesValve.java:246)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,898 ERROR [STDERR] 	at
org.jboss.web.tomcat.tc4.statistics.ContainerStatsValve.invoke(ContainerStatsValve.java:76)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,898 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:480)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:995)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardContext.invoke(StandardContext.java:2417)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:180)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:643)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.valves.ErrorDispatcherValve.invoke(ErrorDispatcherValve.java:171)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:172)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,908 ERROR [STDERR] 	at
org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(SecurityAssociationValve.java:65)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:577)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:641)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:480)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:995)
12:12:09,908 ERROR [STDERR] 	at
org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:174)
12:12:09,918 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline$StandardPipelineValveContext.invokeNext(StandardPipeline.java:643)
12:12:09,918 ERROR [STDERR] 	at
org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:480)
12:12:09,918 ERROR [STDERR] 	at
org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:995)
12:12:09,918 ERROR [STDERR] 	at
org.apache.coyote.tomcat4.CoyoteAdapter.service(CoyoteAdapter.java:197)
12:12:09,918 ERROR [STDERR] 	at
org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:781)
12:12:09,918 ERROR [STDERR] 	at
org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.processConnection(Http11Protocol.java:549)
12:12:09,918 ERROR [STDERR] 	at
org.apache.tomcat.util.net.TcpWorkerThread.runIt(PoolTcpEndpoint.java:605)
12:12:09,918 ERROR [STDERR] 	at
org.apache.tomcat.util.threads.ThreadPool$ControlRunnable.run(ThreadPool.java:677)
12:12:09,918 ERROR [STDERR] 	at
java.lang.Thread.run(Thread.java:534)

Code Snippets
---------------

private void runDuplicateElimination1()
	{
		try
		{
			String cpaID = "cpa";
			String conversationID = "DupElm";
			String service =
"http://www.supplysolution.com/ebxml20";
			String action = "DuplicateElimination";			
			String transportType = "HTTP";			

			// Sending the same message again to check if the
Duplicate Message Elimination
			// is working . 
			// ebMSS [6.1] - Works based on MessageId in
persistent storage 
			Request mshReq1 = new Request(new
URL(toMshUrl),pong, transportType);
			EbxmlMessage message1 = new EbxmlMessage();
			MessageHeader header1 =
message1.addMessageHeader();

			header1.addFromPartyId("fromPartyId", "Sample2");
			header1.addToPartyId("toPartyId", "Sample2");
			header1.setCpaId(cpaID);
			header1.setConversationId(conversationID);
			header1.setService(service);
			header1.setAction(action);
			header1.setTimestamp(Utility.toUTCString(new
Date()));
			// turning on duplicate elimination 
			header1.setDuplicateElimination() ;
			// using the same messageId generated in the
previous message 

//header1.setMessageId(Utility.generateMessageId(new
Date(), message1));			
			header1.setMessageId( messageId);
			message1.saveChanges();
			System.out.println("  Sending a second message with
messageId of " + messageId + " to check " +
			"DuplicateElimination with duplicate elimination
turned on ");
			message1.writeTo(System.out);
			mshReq1.send(message1);
			mshReq1.unregister();

		}
		catch (Exception e) 
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	private void runDuplicateElimination()
	{
		try
		{
			String cpaID = "cpa";
			String conversationID = "DupElm";
			String service =
"http://www.supplysolution.com/ebxml20";
			String action = "DuplicateElimination";			
			String transportType = "HTTP";

			Request mshReq = new Request(new
URL(toMshUrl),pong, transportType);
			EbxmlMessage message = new EbxmlMessage();
			MessageHeader header = message.addMessageHeader();

			header.addFromPartyId("fromPartyId", "Sample2");
			header.addToPartyId("toPartyId", "Sample2");
			header.setCpaId(cpaID);
			header.setConversationId(conversationID);
			header.setService(service);
			header.setAction(action);
			header.setTimestamp(Utility.toUTCString(new
Date()));
			header.setDuplicateElimination();
			messageId = Utility.generateMessageId(new Date(),
message);
			header.setMessageId(messageId);			
			message.saveChanges();
			System.out.println("  Sending a message with
messageId of " + messageId + " to check " +
					"DuplicateElimination ");
			message.writeTo(System.out);
			mshReq.send(message);

		}
		catch (Exception e) 
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

please let me know if i am missing something. 

from the spec looks like - duplication elimination has
to be done based on messageid.

-Venkat

__________________________________
Do you Yahoo!?
Yahoo! Search - Find what youre looking for faster
http://search.yahoo.com