You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2020/03/10 15:16:10 UTC
[activemq] branch master updated: Revert "AMQ-7291 - allow setting
properties after clearProperties for BytesMessage, closes #420"
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/master by this push:
new 6355f50 Revert "AMQ-7291 - allow setting properties after clearProperties for BytesMessage, closes #420"
6355f50 is described below
commit 6355f507c3b8ad5f38853d11e0ae0da58659d0c6
Author: jbonofre <jb...@apache.org>
AuthorDate: Tue Mar 10 16:16:01 2020 +0100
Revert "AMQ-7291 - allow setting properties after clearProperties for BytesMessage, closes #420"
This reverts commit 503416a00167e2910630512426df77ecc32492a2.
---
.../activemq/command/ActiveMQBytesMessage.java | 6 ++++++
.../activemq/command/ActiveMQBytesMessageTest.java | 24 ----------------------
2 files changed, 6 insertions(+), 24 deletions(-)
diff --git a/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java b/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
index 199fd9e..71a39f8 100644
--- a/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
+++ b/activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
@@ -913,6 +913,12 @@ public class ActiveMQBytesMessage extends ActiveMQMessage implements BytesMessag
}
@Override
+ public void setObjectProperty(String name, Object value) throws JMSException {
+ initializeWriting();
+ super.setObjectProperty(name, value);
+ }
+
+ @Override
public String toString() {
return super.toString() + " ActiveMQBytesMessage{ " + "bytesOut = " + bytesOut + ", dataOut = " + dataOut + ", dataIn = " + dataIn + " }";
}
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java
index 6b01d05..0219815 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java
@@ -269,30 +269,6 @@ public class ActiveMQBytesMessageTest extends TestCase {
}
}
- public void testClearProperties() throws Exception {
- ActiveMQBytesMessage bytesMessage = new ActiveMQBytesMessage();
- bytesMessage.setIntProperty("one", 1);
- // simulate send
- bytesMessage.onSend();
-
- assertEquals(1, bytesMessage.getIntProperty("one"));
- assertTrue(bytesMessage.isReadOnlyProperties());
-
- try {
- bytesMessage.setIntProperty("two", 2);
- fail("should have thrown b/c readonly");
- } catch (MessageNotWriteableException expected) {
- }
-
- // allow writing new properties
- bytesMessage.clearProperties();
- assertFalse(bytesMessage.propertyExists("one"));
- assertFalse(bytesMessage.isReadOnlyProperties());
-
- bytesMessage.setIntProperty("two", 2);
- assertEquals(2, bytesMessage.getIntProperty("two"));
- }
-
public void testReset() throws JMSException {
ActiveMQBytesMessage message = new ActiveMQBytesMessage();
try {