Package org.gearman.common

Class GearmanNIOJobServerConnection

java.lang.Object

org.gearman.common.GearmanNIOJobServerConnection

All Implemented Interfaces:

GearmanJobServerConnection, GearmanJobServerIpConnection

public class GearmanNIOJobServerConnection
extends Object
implements GearmanJobServerIpConnection

Constructor Summary

Constructors

Constructor	Description
GearmanNIOJobServerConnection(String hostname)
GearmanNIOJobServerConnection(String hostname, int port)
GearmanNIOJobServerConnection(InetSocketAddress remote)

Method Summary

Modifier and Type	Method	Description
boolean	canRead()	Can a read operation be executed at this time.
boolean	canWrite()	Can a write operation be executed at this time.
void	close()	Closes a connection to the Gearman Job Server.
boolean	equals(Object that)
String	getHost()
int	getPort()
Selector	getSelector()
boolean	hasBufferedWriteData()
int	hashCode()
boolean	isOpen()	Is the connection open.
void	open()	Open the connection to the Gearman Job Server.
GearmanPacket	read()	Reads a GearmanPacket from the connection with the Gearman Job Server.
SelectionKey	registerSelector(Selector s, int mask)
String	toString()
void	write(GearmanPacket request)	Writes a GearmanPacket into the connection with the Gearman Job Server.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

GearmanNIOJobServerConnection

public GearmanNIOJobServerConnection(String hostname)
                              throws IllegalArgumentException

Throws:

IllegalArgumentException

GearmanNIOJobServerConnection

public GearmanNIOJobServerConnection(String hostname,
                                     int port)
                              throws IllegalArgumentException

Throws:

IllegalArgumentException

GearmanNIOJobServerConnection

public GearmanNIOJobServerConnection(InetSocketAddress remote)
                              throws IllegalArgumentException

Throws:

IllegalArgumentException

Method Detail

toString

public String toString()

Overrides:

toString in class Object

open

public void open()
          throws IOException

Description copied from interface: GearmanJobServerConnection

Open the connection to the Gearman Job Server.

Specified by:

open in interface GearmanJobServerConnection

Throws:

IOException - if an I/O exception was encountered.

close

public void close()

Description copied from interface: GearmanJobServerConnection

Closes a connection to the Gearman Job Server.

Specified by:

close in interface GearmanJobServerConnection

write

public void write(GearmanPacket request)
           throws IOException

Description copied from interface: GearmanJobServerConnection

Writes a GearmanPacket into the connection with the Gearman Job Server.

Specified by:

write in interface GearmanJobServerConnection

Parameters:

request - The request to be written.

Throws:

IOException - if an I/O exception was encountered.

read

public GearmanPacket read()
                   throws IOException

Description copied from interface: GearmanJobServerConnection

Reads a GearmanPacket from the connection with the Gearman Job Server.

Specified by:

read in interface GearmanJobServerConnection

Returns:

the GearmanPacket read from the connection.

Throws:

IOException - if an I/O exception was encountered.

registerSelector

public SelectionKey registerSelector(Selector s,
                                     int mask)
                              throws IOException

Throws:

IOException

canRead

public boolean canRead()

Description copied from interface: GearmanJobServerConnection

Can a read operation be executed at this time.

Specified by:

canRead in interface GearmanJobServerConnection

Returns:

true if a read can be executed, else returns false.

canWrite

public boolean canWrite()

Description copied from interface: GearmanJobServerConnection

Can a write operation be executed at this time.

Specified by:

canWrite in interface GearmanJobServerConnection

Returns:

true if a write can be executed, else returns false.

hasBufferedWriteData

public boolean hasBufferedWriteData()

getSelector

public Selector getSelector()

isOpen

public boolean isOpen()

Description copied from interface: GearmanJobServerConnection

Is the connection open.

Specified by:

isOpen in interface GearmanJobServerConnection

Returns:

true if the connection is open, else false.

equals

public boolean equals(Object that)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getHost

public String getHost()

Specified by:

getHost in interface GearmanJobServerIpConnection

Returns:

The host-name or address of the Gearman Job Server

getPort

public int getPort()

Specified by:

getPort in interface GearmanJobServerIpConnection

Returns:

The port used to connect to the Gearman Job Server