activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [25/36] activemq-artemis git commit: removing dead code and docs
Date Fri, 03 Mar 2017 01:05:18 GMT
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/3461ed6f
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3461ed6f
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3461ed6f

Branch: refs/heads/artemis-1009
Commit: 3461ed6f732015bd5db1b96089bf884c586caa1a
Parents: 6fd9296
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Wed Mar 1 10:54:40 2017 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Mar 2 20:04:30 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/3461ed6f/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/3461ed6f/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/3461ed6f/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/3461ed6f/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) {


Mime
View raw message