Author: arnaudsimon
Date: Fri Apr 4 05:11:38 2008
New Revision: 644689
URL: http://svn.apache.org/viewvc?rev=644689&view=rev
Log:
QPID-798 Added boolean property fully_sync when true a sync is sent after a
persistent message is transfered. .
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java?rev=644689&r1=644688&r2=644689&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Fri Apr 4 05:11:38 2008
@@ -22,6 +22,7 @@
import javax.jms.JMSException;
import javax.jms.Message;
+import javax.jms.DeliveryMode;
import org.apache.qpid.client.message.AbstractJMSMessage;
import org.apache.qpid.client.message.FiledTableSupport;
@@ -186,9 +187,15 @@
try
{
((AMQSession_0_10)
getSession()).getQpidSession().messageTransfer(destination.getExchangeName().toString(),
-
message.get010Message(),
-
org.apache.qpidity.nclient.Session.TRANSFER_CONFIRM_MODE_NOT_REQUIRED,
-
org.apache.qpidity.nclient.Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE);
+ message.get010Message(),
+
org.apache.qpidity.nclient.Session.TRANSFER_CONFIRM_MODE_NOT_REQUIRED,
+
org.apache.qpidity.nclient.Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE);
+ if(deliveryMode == DeliveryMode.PERSISTENT &&
ClientProperties.FULLY_SYNC )
+ {
+ // we need to sync the delivery of this message
+ ((AMQSession_0_10) getSession()).getQpidSession().sync();
+ }
+
}
catch (IOException e)
{
