summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/transport/TransportMessage.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/java/org/elasticsearch/transport/TransportMessage.java')
-rw-r--r--core/src/main/java/org/elasticsearch/transport/TransportMessage.java26
1 files changed, 6 insertions, 20 deletions
diff --git a/core/src/main/java/org/elasticsearch/transport/TransportMessage.java b/core/src/main/java/org/elasticsearch/transport/TransportMessage.java
index f52f9179dd..1434a6eaa7 100644
--- a/core/src/main/java/org/elasticsearch/transport/TransportMessage.java
+++ b/core/src/main/java/org/elasticsearch/transport/TransportMessage.java
@@ -19,29 +19,20 @@
package org.elasticsearch.transport;
-import org.elasticsearch.common.ContextAndHeaderHolder;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Streamable;
import org.elasticsearch.common.transport.TransportAddress;
import java.io.IOException;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
-/**
- * The transport message is also a {@link ContextAndHeaderHolder context holder} that holds <b>transient</b> context, that is,
- * the context is not serialized with message.
- */
-public abstract class TransportMessage<TM extends TransportMessage<TM>> extends ContextAndHeaderHolder implements Streamable {
+public abstract class TransportMessage<TM extends TransportMessage<TM>> implements Streamable {
private TransportAddress remoteAddress;
- protected TransportMessage() {
- }
-
- protected TransportMessage(TM message) {
- copyContextAndHeadersFrom(message);
- }
-
public void remoteAddress(TransportAddress remoteAddress) {
this.remoteAddress = remoteAddress;
}
@@ -52,16 +43,11 @@ public abstract class TransportMessage<TM extends TransportMessage<TM>> extends
@Override
public void readFrom(StreamInput in) throws IOException {
- headers = in.readBoolean() ? in.readMap() : null;
+
}
@Override
public void writeTo(StreamOutput out) throws IOException {
- if (headers == null) {
- out.writeBoolean(false);
- } else {
- out.writeBoolean(true);
- out.writeMap(headers);
- }
+
}
}