com.couchbase.lite.internal.replicator

Class MessageSocket

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

com.couchbase.lite.internal.core.C4NativePeer

com.couchbase.lite.internal.core.C4Socket

com.couchbase.lite.internal.replicator.MessageSocket

All Implemented Interfaces:

ReplicatorConnection, Serializable

public class MessageSocket
extends C4Socket
implements ReplicatorConnection

See Also:

Serialized Form

Field Summary

Fields inherited from class com.couchbase.lite.internal.core.C4Socket

NO_FRAMING, WEB_SOCKET_CLIENT_FRAMING, WEB_SOCKET_SERVER_FRAMING, WS_STATUS_CLOSE_ABNORMAL, WS_STATUS_CLOSE_BAD_MESSAGE_FORMAT, WS_STATUS_CLOSE_CANT_FULFILL, WS_STATUS_CLOSE_DATA_ERROR, WS_STATUS_CLOSE_MESSAGE_TO_BIG, WS_STATUS_CLOSE_MISSING_EXTENSION, WS_STATUS_CLOSE_NO_CODE, WS_STATUS_CLOSE_NORMAL, WS_STATUS_CLOSE_POLICY_ERROR, WS_STATUS_CLOSE_PROTOCOL_ERROR, WS_STATUS_CLOSE_TLS_FAILURE, WS_STATUS_CLOSE_USER, WS_STATUS_CLOSE_USER_PERMANENT, WS_STATUS_CLOSE_USER_TRANSIENT, WS_STATUS_GOING_AWAY

Constructor Summary

Constructors

Constructor and Description
MessageSocket(long handle, MessageEndpoint endpoint)
MessageSocket(MessageEndpointConnection connection, ProtocolType protocolType)

Method Summary

Modifier and Type	Method and Description
void	close(MessagingError error) Tells the replicator to close the current replicator connection.
void	receive(Message message) Tells the replicator to consume the data received from the other peer.
String	toString()

Methods inherited from class java.util.concurrent.atomic.AtomicLong

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageSocket

public MessageSocket(long handle,
                     MessageEndpoint endpoint)

MessageSocket

public MessageSocket(MessageEndpointConnection connection,
                     ProtocolType protocolType)

Method Detail

toString

@NonNull
public String toString()

Overrides:

toString in class AtomicLong

close

public void close(MessagingError error)

Description copied from interface: ReplicatorConnection

Tells the replicator to close the current replicator connection. In return, the replicator will call the MessageEndpointConnection's close(error, completion) to acknowledge the closed connection.

Specified by:

close in interface ReplicatorConnection

Parameters:

error - the error if any

receive

public void receive(@NonNull
                    Message message)

Description copied from interface: ReplicatorConnection

Tells the replicator to consume the data received from the other peer.

Specified by:

receive in interface ReplicatorConnection

Parameters:

message - the message