Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

applied fix for AMQ-1232 and AMQ-1275 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546847 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2007-06-13 12:47:29 +00:00
parent 4474eb8a1b
commit 28e6453bad
1 changed files with 21 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
View File

@ -1594,24 +1594,13 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
// tell the Broker we are about to start a new transaction
doStartTransaction();
TransactionId txid=transactionContext.getTransactionId();
message.setJMSDestination(destination);
message.setJMSDeliveryMode(deliveryMode);
long expiration=0L;
if(!producer.getDisableMessageTimestamp()){
long timeStamp=System.currentTimeMillis();
message.setJMSTimestamp(timeStamp);
if(timeToLive>0){
expiration=timeToLive+timeStamp;
}
}
message.setJMSExpiration(expiration);
message.setJMSPriority(priority);
long sequenceNumber=producer.getMessageSequence();
message.setJMSRedelivered(false);
// transform to our own message format here
long sequenceNumber=producer.getMessageSequence();
// transform to our own message format here
ActiveMQMessage msg=ActiveMQMessageTransformation.transformMessage(
message,connection);
// Set the message id.
// Set the message id.
if(msg==message){
msg.setMessageId(new MessageId(producer.getProducerInfo()
.getProducerId(),sequenceNumber));
@ -1620,7 +1609,22 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
.getProducerId(),sequenceNumber));
message.setJMSMessageID(msg.getMessageId().toString());
}
msg.setTransactionId(txid);
msg.setJMSDestination(destination);
msg.setJMSDeliveryMode(deliveryMode);
long expiration=0L;
if(!producer.getDisableMessageTimestamp()){
long timeStamp=System.currentTimeMillis();
msg.setJMSTimestamp(timeStamp);
if(timeToLive>0){
expiration=timeToLive+timeStamp;
}
}
msg.setJMSExpiration(expiration);
msg.setJMSPriority(priority);
msg.setJMSRedelivered(false);
msg.setTransactionId(txid);
if(connection.isCopyMessageOnSend()){
msg=(ActiveMQMessage)msg.copy();
}