Package org.elasticsearch.transport
Class TransportMessage
java.lang.Object
org.elasticsearch.transport.TransportMessage
- All Implemented Interfaces:
Writeable
,org.elasticsearch.common.util.concurrent.RefCounted
- Direct Known Subclasses:
TransportRequest
,TransportResponse
public abstract class TransportMessage extends java.lang.Object implements Writeable, org.elasticsearch.common.util.concurrent.RefCounted
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
Constructor Summary
Constructors Constructor Description TransportMessage()
Constructs a new empty transport messageTransportMessage(StreamInput in)
Constructs a new transport message with the data from theStreamInput
. -
Method Summary
Modifier and Type Method Description boolean
decRef()
void
incRef()
TransportAddress
remoteAddress()
void
remoteAddress(TransportAddress remoteAddress)
boolean
tryIncRef()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
TransportMessage
public TransportMessage()Constructs a new empty transport message -
TransportMessage
Constructs a new transport message with the data from theStreamInput
. This is currently a no-op
-
-
Method Details
-
remoteAddress
-
remoteAddress
-
incRef
public void incRef()- Specified by:
incRef
in interfaceorg.elasticsearch.common.util.concurrent.RefCounted
-
tryIncRef
public boolean tryIncRef()- Specified by:
tryIncRef
in interfaceorg.elasticsearch.common.util.concurrent.RefCounted
-
decRef
public boolean decRef()- Specified by:
decRef
in interfaceorg.elasticsearch.common.util.concurrent.RefCounted
-