Package org.ldaptive.transport

Class MessageFunctional<Q extends Request,S extends Result>

java.lang.Object

org.ldaptive.AbstractFreezable

org.ldaptive.transport.MessageFunctional<Q,S>

Type Parameters:

Q - type of request

S - type of result

All Implemented Interfaces:

Freezable

Direct Known Subclasses:

MessageFunctional.BiConsumer, MessageFunctional.Consumer, MessageFunctional.Function

public abstract class MessageFunctional<Q extends Request,S extends Result>
extends AbstractFreezable

Base class for processing a message that is initialized with properties from the handle.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageFunctional.BiConsumer<Q extends Request,S extends Result,T,U>	Marker class to inject handle properties.
static class	MessageFunctional.Consumer<Q extends Request,S extends Result,T>	Marker class to inject handle properties.
static class	MessageFunctional.Function<Q extends Request,S extends Result,T,R>	Marker class to inject handle properties.

Field Summary

Fields

Modifier and Type	Field	Description
private Connection	connection	Connection the request occurred on.
private OperationHandle<Q,S>	handle	Operation handle that sent the request.
private Q	request	Request that produced the message.

Constructor Summary

Constructors

Constructor	Description
MessageFunctional()

Method Summary

Modifier and Type	Method	Description
Connection	getConnection()	Returns the connection.
OperationHandle<Q,S>	getHandle()	Returns the handle.
Q	getRequest()	Returns the request.
abstract MessageFunctional<Q,S>	newInstance()	Create a new instance of this message functional.
void	setConnection(Connection conn)	Sets the connection.
void	setHandle(OperationHandle<Q,S> h)	Sets the handle.
void	setRequest(Q req)	Sets the request.

Methods inherited from class org.ldaptive.AbstractFreezable

assertMutable, freeze, freeze, freeze, isFrozen

Methods inherited from class java.lang.Object

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

Field Details

connection

private Connection connection

Connection the request occurred on.

request

private Q extends Request request

Request that produced the message.

handle

private OperationHandle<Q extends Request,S extends Result> handle

Operation handle that sent the request.

Constructor Details

MessageFunctional

public MessageFunctional()

Method Details

getConnection

public Connection getConnection()

Returns the connection.

Returns:

connection

setConnection

public void setConnection(Connection conn)

Sets the connection.

Parameters:

conn - connection

getRequest

public Q getRequest()

Returns the request.

Returns:

request

setRequest

public void setRequest(Q req)

Sets the request.

Parameters:

req - request

getHandle

public OperationHandle<Q,S> getHandle()

Returns the handle.

Returns:

handle

setHandle

public void setHandle(OperationHandle<Q,S> h)

Sets the handle.

Parameters:

h - handle

newInstance

public abstract MessageFunctional<Q,S> newInstance()

Create a new instance of this message functional.

Returns:

new instance of this message functional