org.rapidoid.net.impl

Class DefaultExchange<T>

java.lang.Object

org.rapidoid.net.impl.DefaultExchange<T>

All Implemented Interfaces:

org.rapidoid.buffer.BufProvider, ProtocolContext<T>, org.rapidoid.util.Constants, org.rapidoid.util.Resetable

public abstract class DefaultExchange<T>
extends Object
implements ProtocolContext<T>, org.rapidoid.buffer.BufProvider, org.rapidoid.util.Resetable, org.rapidoid.util.Constants

Field Summary

Fields

Modifier and Type	Field and Description
protected Channel	conn
protected long	requestId
protected AtomicLong	totalWritten

Fields inherited from interface org.rapidoid.util.Constants

AMP, ASTERISK, BYTE_0, COL, CR, CR_, CR_LF, CR_LF_CR_LF, EMPTY_ARRAY, EMPTY_STRING_ARRAY, EQ, F, LF, LF_, LF_LF, NOT_FOUND, SEMI_COL, SEPARATOR_LINE, SPACE, SPACE_, T, UTF_8

Constructor Summary

Constructors

Constructor and Description
DefaultExchange()

Method Summary

Modifier and Type	Method and Description
String	address()
T	async()
protected org.rapidoid.data.BinaryMultiData	binaryMultiData(org.rapidoid.data.KeyValueRanges ranges)
org.rapidoid.buffer.Buf	buffer()
T	close()
T	closeIf(boolean condition)
long	connId()
protected org.rapidoid.data.Data	data(org.rapidoid.data.Range range)
protected org.rapidoid.data.Data	decodedData(org.rapidoid.data.Range range)
T	done()
InetSocketAddress	getAddress()
long	getTotalWritten()
RapidoidHelper	helper()
org.rapidoid.buffer.Buf	input()
boolean	isAsync()
protected T	me()
protected org.rapidoid.data.MultiData	multiData(org.rapidoid.data.KeyValueRanges ranges)
org.rapidoid.buffer.Buf	output()
String	readln()
String	readN(int count)
long	requestId()
void	reset()
void	setConnection(Channel conn)
T	write(byte[] bytes)
T	write(byte[] bytes, int offset, int length)
T	write(ByteBuffer buf)
T	write(File file)
T	write(String s)
T	writeJSON(Object value)
T	writeln(String s)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.rapidoid.net.abstracts.ProtocolContext

isClosed, isClosing, isInitial, log, send, state, waitUntilClosing

Field Detail

conn

protected Channel conn

totalWritten

protected AtomicLong totalWritten

requestId

protected long requestId

Constructor Detail

DefaultExchange

public DefaultExchange()

Method Detail

reset

public void reset()

Specified by:

reset in interface org.rapidoid.util.Resetable

setConnection

public void setConnection(Channel conn)

address

public String address()

Specified by:

address in interface ProtocolContext<T>

write

public T write(String s)

Specified by:

write in interface ProtocolContext<T>

writeln

public T writeln(String s)

Specified by:

writeln in interface ProtocolContext<T>

write

public T write(byte[] bytes)

Specified by:

write in interface ProtocolContext<T>

write

public T write(byte[] bytes,
               int offset,
               int length)

Specified by:

write in interface ProtocolContext<T>

write

public T write(ByteBuffer buf)

Specified by:

write in interface ProtocolContext<T>

write

public T write(File file)

Specified by:

write in interface ProtocolContext<T>

writeJSON

public T writeJSON(Object value)

Specified by:

writeJSON in interface ProtocolContext<T>

close

public T close()

Specified by:

close in interface ProtocolContext<T>

closeIf

public T closeIf(boolean condition)

Specified by:

closeIf in interface ProtocolContext<T>

input

public org.rapidoid.buffer.Buf input()

Specified by:

input in interface ProtocolContext<T>

output

public org.rapidoid.buffer.Buf output()

Specified by:

output in interface ProtocolContext<T>

readln

public String readln()

Specified by:

readln in interface ProtocolContext<T>

readN

public String readN(int count)

Specified by:

readN in interface ProtocolContext<T>

getAddress

public InetSocketAddress getAddress()

Specified by:

getAddress in interface ProtocolContext<T>

helper

public RapidoidHelper helper()

Specified by:

helper in interface ProtocolContext<T>

connId

public long connId()

Specified by:

connId in interface ProtocolContext<T>

data

protected org.rapidoid.data.Data data(org.rapidoid.data.Range range)

decodedData

protected org.rapidoid.data.Data decodedData(org.rapidoid.data.Range range)

multiData

protected org.rapidoid.data.MultiData multiData(org.rapidoid.data.KeyValueRanges ranges)

binaryMultiData

protected org.rapidoid.data.BinaryMultiData binaryMultiData(org.rapidoid.data.KeyValueRanges ranges)

buffer

public org.rapidoid.buffer.Buf buffer()

Specified by:

buffer in interface org.rapidoid.buffer.BufProvider

getTotalWritten

public long getTotalWritten()

async

public T async()

Specified by:

async in interface ProtocolContext<T>

isAsync

public boolean isAsync()

Specified by:

isAsync in interface ProtocolContext<T>

done

public T done()

Specified by:

done in interface ProtocolContext<T>

me

protected T me()

requestId

public long requestId()

Specified by:

requestId in interface ProtocolContext<T>