Top Fields Constructors Methods

io.vertx.core.eventbus.impl.clustered

pack-priv Class ConnectionHolder

Class Inheritance

extends Object

java.lang.Object
io.vertx.core.eventbus.impl.clustered.ConnectionHolder

Imports

io.vertx.core.Promise, io.vertx.core.buffer.Buffer, io.vertx.core.eventbus.EventBusOptions, io.vertx.core.eventbus.impl.OutboundDeliveryContext, io.vertx.core.eventbus.impl.codecs.PingMessageCodec, io.vertx.core.impl.VertxInternal, io.vertx.core.impl.logging.Logger, .LoggerFactory, io.vertx.core.net.NetSocket, io.vertx.core.net.impl.ConnectionBase, io.vertx.core.spi.cluster.NodeInfo, io.vertx.core.spi.metrics.EventBusMetrics, java.util.ArrayDeque, .Queue

Author: Tim Fox

Field Summary

Modifier and Type	Field and Description
private boolean	connected
private final ClusteredEventBus	eventBus
private static final Logger	log
private final EventBusMetrics<H>	metrics
private Queue<OutboundDeliveryContext<?>>	pending
private static final String	PING_ADDRESS
private long	pingTimeoutID
private final String	remoteNodeId
private NetSocket	socket
private long	timeoutID
private final VertxInternal	vertx

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectionHolder(ClusteredEventBus eventBus, String remoteNodeId)

Method Summary

Modifier and Type	Method and Description
pack-priv void	close()
private void	close(Throwable cause)
pack-priv void	connect()
private synchronized void	connected(NetSocket socket)
private void	schedulePing()
pack-priv synchronized void	writeMessage(OutboundDeliveryContext<?> ctx)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connected	back to summary
private boolean connected

eventBus	back to summary
private final ClusteredEventBus eventBus

log	back to summary
private static final Logger log

metrics	back to summary
private final EventBusMetrics<H> metrics

pending	back to summary
private Queue<OutboundDeliveryContext<?>> pending

PING_ADDRESS	back to summary
private static final String PING_ADDRESS

pingTimeoutID	back to summary
private long pingTimeoutID

remoteNodeId	back to summary
private final String remoteNodeId

socket	back to summary
private NetSocket socket

timeoutID	back to summary
private long timeoutID

vertx	back to summary
private final VertxInternal vertx

Constructor Detail

ConnectionHolder	back to summary
pack-priv ConnectionHolder(ClusteredEventBus eventBus, String remoteNodeId)

Method Detail

close	back to summary
pack-priv void close()

close	back to summary
private void close(Throwable cause)

connect	back to summary
pack-priv void connect()

connected	back to summary
private synchronized void connected(NetSocket socket)

schedulePing	back to summary
private void schedulePing()

writeMessage	back to summary
pack-priv synchronized void writeMessage(OutboundDeliveryContext<?> ctx)