removing dead code and docs
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a3330457 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a3330457 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a3330457 Branch: refs/heads/artemis-1009 Commit: a3330457e7e68f39caf3018115885ccb45e7f342 Parents: 03fdc20 Author: Clebert Suconic <[email protected]> Authored: Wed Mar 1 10:54:40 2017 -0500 Committer: Clebert Suconic <[email protected]> Committed: Thu Mar 2 10:05:21 2017 -0500 ---------------------------------------------------------------------- .../activemq/artemis/api/core/Message.java | 6 ------ .../artemis/core/message/impl/CoreMessage.java | 19 ------------------- .../protocol/amqp/broker/AMQPMessage.java | 3 --- .../converter/message/InboundTransformer.java | 2 -- 4 files changed, 30 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a3330457/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java index a6ef408..d96f232 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java @@ -69,12 +69,6 @@ import org.apache.activemq.artemis.core.persistence.Persister; * size = encode.getEncodeSize(); * encode.encodeDirectly(bufferOutput); * - * - * Disabling temporary buffer: - * - * // This will make the message to only be encoded directly to the output stream, useful on client core API - * encode.disableInternalBuffer(); - */ public interface Message { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a3330457/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java index edbcaa9..973c1de 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java @@ -541,25 +541,6 @@ public class CoreMessage extends RefCountMessage { return false; } - private void encodeBody(ByteBuf intoBuffer) { - intoBuffer.writerIndex(DataConstants.SIZE_INT); - - switch (getBodyType()) { - - // TODO-now implement other types - case Text: - SimpleString.writeNullableSimpleString(intoBuffer, SimpleString.toSimpleString(body == null ? null : body.toString())); - break; - - default: - break; - } - - - endOfBodyPosition = buffer.writerIndex() + BUFFER_HEADER_SPACE; - buffer.setInt(0, endOfBodyPosition); - } - @Override public String getAddress() { if (address == null) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a3330457/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java index c963061..7fabefd 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java @@ -488,9 +488,6 @@ public class AMQPMessage extends RefCountMessage { @Override public void sendBuffer(ByteBuf buffer, int deliveryCount) { - // TODO: do I need to change the Header with deliveryCount? - // I would send a new instance of Header with a new delivery count, and only send partial of the buffer - // previously received checkBuffer(); Header header = getHeader(); if (header != null) { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a3330457/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/InboundTransformer.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/InboundTransformer.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/InboundTransformer.java index cec34ef..1e83959 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/InboundTransformer.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/InboundTransformer.java @@ -58,8 +58,6 @@ public abstract class InboundTransformer { protected IDGenerator idGenerator; - public static final String TRANSFORMER_NATIVE = "native"; - public static final String TRANSFORMER_RAW = "raw"; public static final String TRANSFORMER_JMS = "jms"; public InboundTransformer(IDGenerator idGenerator) {
