org.elasticsearch.transport

Class TransportMessage<TM extends TransportMessage<TM>>

java.lang.Object

org.elasticsearch.common.ContextAndHeaderHolder

org.elasticsearch.transport.TransportMessage<TM>

All Implemented Interfaces:

HasContext, HasContextAndHeaders, HasHeaders, Streamable

Direct Known Subclasses:

TransportRequest, TransportResponse

public abstract class TransportMessage<TM extends TransportMessage<TM>>
extends ContextAndHeaderHolder
implements Streamable

The transport message is also a context holder that holds transient context, that is, the context is not serialized with message.

Field Summary

Fields inherited from class org.elasticsearch.common.ContextAndHeaderHolder

headers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransportMessage()
protected	TransportMessage(TM message)

Method Summary

Modifier and Type	Method and Description
TransportMessage	putHeader(String key, Object value)
void	readFrom(StreamInput in)
TransportAddress	remoteAddress()
void	remoteAddress(TransportAddress remoteAddress)
void	writeTo(StreamOutput out)

Methods inherited from class org.elasticsearch.common.ContextAndHeaderHolder

contextSize, copyContextAndHeadersFrom, copyContextFrom, copyHeadersFrom, getContext, getFromContext, getFromContext, getHeader, getHeaders, hasHeader, hasInContext, isContextEmpty, putAllInContext, putInContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportMessage

protected TransportMessage()

TransportMessage

protected TransportMessage(TM message)

Method Detail

remoteAddress

public void remoteAddress(TransportAddress remoteAddress)

remoteAddress

public TransportAddress remoteAddress()

putHeader

public TransportMessage putHeader(String key,
                                  Object value)

Specified by:

putHeader in interface HasHeaders

Overrides:

putHeader in class ContextAndHeaderHolder

readFrom

public void readFrom(StreamInput in)
              throws IOException

Specified by:

readFrom in interface Streamable

Throws:

IOException

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Streamable

Throws:

IOException