Module com.aoindustries.aoserv.daemon.client

Package com.aoindustries.aoserv.daemon.client

Class AoservDaemonConnection

java.lang.Object

com.aoindustries.aoserv.daemon.client.AoservDaemonConnection

All Implemented Interfaces:

Closeable, AutoCloseable

public final class AoservDaemonConnection
extends Object
implements Closeable

A connection between an AOServ Daemon Client and an AOServ Daemon.

Author:

AO Industries, Inc.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AoservDaemonConnection(AoservDaemonConnector connector)	Creates a new AoservConnection.

Method Summary

Modifier and Type	Method	Description
void	abort()	Closes this connection to the server so that a reconnect is forced in the future.
Throwable	abort(Throwable t0)	Closes this connection to the server so that a reconnect is forced in the future.
void	close()	Releases this connection back to the pool.
AoservDaemonProtocol.Version	getProtocolVersion()	Gets the protocol negotiated for this connection.
StreamableOutput	getRequestOut(int taskCode)	Begins a task and gets the stream to write to the server.
StreamableInput	getResponseIn()	Gets the stream to read from the server.

Methods inherited from class java.lang.Object

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

Constructor Details

AoservDaemonConnection

protected AoservDaemonConnection(AoservDaemonConnector connector)
                          throws IOException

Creates a new AoservConnection.

TODO: Once all daemons are running > version 1.77, can simplify this considerably

Throws:

IOException

Method Details

close

public void close()
           throws IOException

Releases this connection back to the pool.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

See Also:

• AoservDaemonConnector.release(com.aoindustries.aoserv.daemon.client.AoservDaemonConnection)

abort

public Throwable abort(Throwable t0)

Closes this connection to the server so that a reconnect is forced in the future. Adds any new throwables to t0 via Throwables.addSuppressed(java.lang.Throwable, java.lang.Throwable).

abort

public void abort()
           throws IOException

Closes this connection to the server so that a reconnect is forced in the future.

Throws:

IOException

getRequestOut

public StreamableOutput getRequestOut(int taskCode)
                               throws IOException

Begins a task and gets the stream to write to the server.

Throws:

IOException

getResponseIn

public StreamableInput getResponseIn()
                              throws IOException

Gets the stream to read from the server.

Throws:

IOException

getProtocolVersion

public AoservDaemonProtocol.Version getProtocolVersion()

Gets the protocol negotiated for this connection.