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

ARTEMIS-2023 Fix missing setEnable1x methods

This commit is contained in:
Martyn Taylor 2018-08-17 15:55:39 +01:00 committed by Justin Bertram
parent 0dff36e00b
commit 3952bcdbe8
2 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
View File

@ -144,28 +144,36 @@ public class ActiveMQSession implements QueueSession, TopicSession {
public BytesMessage createBytesMessage() throws JMSException { public BytesMessage createBytesMessage() throws JMSException {
checkClosed(); checkClosed();
return new ActiveMQBytesMessage(session); ActiveMQBytesMessage message = new ActiveMQBytesMessage(session);
message.setEnable1xPrefixes(enable1xPrefixes);
return message;
} }
@Override @Override
public MapMessage createMapMessage() throws JMSException { public MapMessage createMapMessage() throws JMSException {
checkClosed(); checkClosed();
return new ActiveMQMapMessage(session); ActiveMQMapMessage message = new ActiveMQMapMessage(session);
message.setEnable1xPrefixes(enable1xPrefixes);
return message;
} }
@Override @Override
public Message createMessage() throws JMSException { public Message createMessage() throws JMSException {
checkClosed(); checkClosed();
return new ActiveMQMessage(session); ActiveMQMessage message = new ActiveMQMessage(session);
message.setEnable1xPrefixes(enable1xPrefixes);
return message;
} }
@Override @Override
public ObjectMessage createObjectMessage() throws JMSException { public ObjectMessage createObjectMessage() throws JMSException {
checkClosed(); checkClosed();
return new ActiveMQObjectMessage(session, options); ActiveMQObjectMessage message = new ActiveMQObjectMessage(session, options);
message.setEnable1xPrefixes(enable1xPrefixes);
return message;
} }
@Override @Override
@ -173,8 +181,8 @@ public class ActiveMQSession implements QueueSession, TopicSession {
checkClosed(); checkClosed();
ActiveMQObjectMessage msg = new ActiveMQObjectMessage(session, options); ActiveMQObjectMessage msg = new ActiveMQObjectMessage(session, options);
msg.setObject(object); msg.setObject(object);
msg.setEnable1xPrefixes(enable1xPrefixes);
return msg; return msg;
} }
@ -183,7 +191,9 @@ public class ActiveMQSession implements QueueSession, TopicSession {
public StreamMessage createStreamMessage() throws JMSException { public StreamMessage createStreamMessage() throws JMSException {
checkClosed(); checkClosed();
return new ActiveMQStreamMessage(session); ActiveMQStreamMessage message = new ActiveMQStreamMessage(session);
message.setEnable1xPrefixes(enable1xPrefixes);
return message;
} }
@Override @Override
@ -191,8 +201,8 @@ public class ActiveMQSession implements QueueSession, TopicSession {
checkClosed(); checkClosed();
ActiveMQTextMessage msg = new ActiveMQTextMessage(session); ActiveMQTextMessage msg = new ActiveMQTextMessage(session);
msg.setText(null); msg.setText(null);
msg.setEnable1xPrefixes(enable1xPrefixes);
return msg; return msg;
} }
@ -202,8 +212,8 @@ public class ActiveMQSession implements QueueSession, TopicSession {
checkClosed(); checkClosed();
ActiveMQTextMessage msg = new ActiveMQTextMessage(session); ActiveMQTextMessage msg = new ActiveMQTextMessage(session);
msg.setText(text); msg.setText(text);
msg.setEnable1xPrefixes(enable1xPrefixes);
return msg; return msg;
} }

2
artemis-ra/src/main/java/org/apache/activemq/artemis/ra/inflow/ActiveMQMessageHandler.java
View File

@ -282,6 +282,8 @@ public class ActiveMQMessageHandler implements MessageHandler, FailoverEventList
} }
ActiveMQMessage msg = ActiveMQMessage.createMessage(message, session, options); ActiveMQMessage msg = ActiveMQMessage.createMessage(message, session, options);
msg.setEnable1xPrefixes(activation.getConnectionFactory().isEnable1xPrefixes());
boolean beforeDelivery = false; boolean beforeDelivery = false;
try { try {