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

ARTEMIS-3529 Moving addItem from AMQP and Core into upper class

This commit is contained in:
Clebert Suconic 2021-10-17 20:06:51 -04:00
parent a833d95c1f
commit 6bb4aa7a10
3 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java
View File

@ -1336,7 +1336,6 @@ public class CoreMessage extends RefCountMessage implements ICoreMessage {
protected void init() throws OpenDataException { protected void init() throws OpenDataException {
super.init(); super.init();
body = new ArrayType(SimpleType.BYTE, true); body = new ArrayType(SimpleType.BYTE, true);
addItem(CompositeDataConstants.TYPE, CompositeDataConstants.TYPE_DESCRIPTION, SimpleType.BYTE);
addItem(CompositeDataConstants.BODY, CompositeDataConstants.BODY_DESCRIPTION, body); addItem(CompositeDataConstants.BODY, CompositeDataConstants.BODY_DESCRIPTION, body);
} }
@ -1360,7 +1359,6 @@ public class CoreMessage extends RefCountMessage implements ICoreMessage {
@Override @Override
protected void init() throws OpenDataException { protected void init() throws OpenDataException {
super.init(); super.init();
addItem(CompositeDataConstants.TYPE, CompositeDataConstants.TYPE_DESCRIPTION, SimpleType.BYTE);
addItem(CompositeDataConstants.TEXT_BODY, CompositeDataConstants.TEXT_BODY, SimpleType.STRING); addItem(CompositeDataConstants.TEXT_BODY, CompositeDataConstants.TEXT_BODY, SimpleType.STRING);
} }

2
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/openmbean/MessageOpenTypeFactory.java
View File

@ -74,7 +74,7 @@ public class MessageOpenTypeFactory<M extends Message> {
} }
protected void init() throws OpenDataException { protected void init() throws OpenDataException {
addItem(CompositeDataConstants.TYPE, CompositeDataConstants.TYPE_DESCRIPTION, SimpleType.BYTE);
addItem(CompositeDataConstants.ADDRESS, CompositeDataConstants.ADDRESS_DESCRIPTION, SimpleType.STRING); addItem(CompositeDataConstants.ADDRESS, CompositeDataConstants.ADDRESS_DESCRIPTION, SimpleType.STRING);
addItem(CompositeDataConstants.MESSAGE_ID, CompositeDataConstants.MESSAGE_ID_DESCRIPTION, SimpleType.STRING); addItem(CompositeDataConstants.MESSAGE_ID, CompositeDataConstants.MESSAGE_ID_DESCRIPTION, SimpleType.STRING);
addItem(CompositeDataConstants.USER_ID, CompositeDataConstants.USER_ID_DESCRIPTION, SimpleType.STRING); addItem(CompositeDataConstants.USER_ID, CompositeDataConstants.USER_ID_DESCRIPTION, SimpleType.STRING);

1
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
View File

@ -1803,7 +1803,6 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache.
protected void init() throws OpenDataException { protected void init() throws OpenDataException {
super.init(); super.init();
addItem(CompositeDataConstants.TEXT_BODY, CompositeDataConstants.TEXT_BODY, SimpleType.STRING); addItem(CompositeDataConstants.TEXT_BODY, CompositeDataConstants.TEXT_BODY, SimpleType.STRING);
addItem(CompositeDataConstants.TYPE, CompositeDataConstants.TYPE_DESCRIPTION, SimpleType.BYTE);
} }
@Override @Override