zmq

Class TcpConnecter

java.lang.Object

zmq.ZObject

zmq.Own

zmq.TcpConnecter

All Implemented Interfaces:

IPollEvents

Direct Known Subclasses:

IpcConnecter

public class TcpConnecter
extends Own
implements IPollEvents

Field Summary

Fields

Modifier and Type	Field and Description
private Address	addr
private Address	address
private int	currentReconnectIvl
private boolean	delayedStart
private java.nio.channels.SocketChannel	handle
private boolean	handleValid
private IOObject	ioObject
private static int	RECONNECT_TIMER_ID
private SessionBase	session
private SocketBase	socket
private boolean	timerStarted

Fields inherited from class zmq.Own

options

Constructor Summary

Constructors

Constructor and Description
TcpConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, boolean delayedStart)

Method Summary

Modifier and Type	Method and Description
void	acceptEvent()
private void	addreconnectTimer()
private void	close()
private java.nio.channels.SocketChannel	connect()
void	connectEvent()
void	destroy()
private int	getNewReconnectIvl()
void	inEvent()
private boolean	open()
void	outEvent()
protected void	processPlug()
protected void	processTerm(int linger)
private void	startConnecting()
void	timerEvent(int id)
java.lang.String	toString()

Methods inherited from class zmq.Own

incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAck

Methods inherited from class zmq.ZObject

chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints

Methods inherited from class java.lang.Object

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

Field Detail

RECONNECT_TIMER_ID

private static final int RECONNECT_TIMER_ID

See Also:

Constant Field Values

ioObject

private final IOObject ioObject

addr

private final Address addr

handle

private java.nio.channels.SocketChannel handle

handleValid

private boolean handleValid

delayedStart

private final boolean delayedStart

timerStarted

private boolean timerStarted

session

private final SessionBase session

currentReconnectIvl

private int currentReconnectIvl

address

private final Address address

socket

private final SocketBase socket

Constructor Detail

TcpConnecter

public TcpConnecter(IOThread ioThread,
                    SessionBase session,
                    Options options,
                    Address addr,
                    boolean delayedStart)

Method Detail

destroy

public void destroy()

Specified by:

destroy in class Own

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

startConnecting

private void startConnecting()

addreconnectTimer

private void addreconnectTimer()

getNewReconnectIvl

private int getNewReconnectIvl()

open

private boolean open()
              throws java.io.IOException

Throws:

java.io.IOException

connect

private java.nio.channels.SocketChannel connect()
                                         throws java.io.IOException

Throws:

java.io.IOException

close

private void close()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object