org.msgpack.rpc.transport
Class PooledStreamClientTransport<Channel,PendingBuffer extends java.io.OutputStream>

java.lang.Object
  org.msgpack.rpc.transport.PooledStreamClientTransport<Channel,PendingBuffer>

All Implemented Interfaces:

java.io.Closeable, ClientTransport, MessageSendable

public abstract class PooledStreamClientTransport<Channel,PendingBuffer extends java.io.OutputStream>
extends java.lang.Object
implements ClientTransport

Field Summary

protected StreamClientConfig	config
protected Session	session

Constructor Summary

PooledStreamClientTransport(StreamClientConfig config, Session session)

Method Summary

void	close()
protected abstract void	closeChannel(Channel c)
protected abstract void	closePendingBuffer(PendingBuffer b)
protected abstract void	flushPendingBuffer(PendingBuffer b, Channel c)
protected StreamClientConfig	getConfig()
protected PendingBuffer	getPendingBuffer()
protected Session	getSession()
protected abstract PendingBuffer	newPendingBuffer()
void	onClosed(Channel c)
void	onConnected(Channel c)
void	onConnectFailed(java.lang.Throwable cause)
protected abstract void	resetPendingBuffer(PendingBuffer b)
void	sendMessage(java.lang.Object msg)
protected abstract void	sendMessageChannel(Channel c, java.lang.Object msg)
protected abstract void	startConnection()

Methods inherited from class java.lang.Object

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

Field Detail

session

protected final Session session

config

protected final StreamClientConfig config

Constructor Detail

PooledStreamClientTransport

public PooledStreamClientTransport(StreamClientConfig config,
                                   Session session)

Method Detail

getSession

protected Session getSession()

getConfig

protected StreamClientConfig getConfig()

sendMessage

public void sendMessage(java.lang.Object msg)

Specified by:

sendMessage in interface ClientTransport

Specified by:

sendMessage in interface MessageSendable

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface ClientTransport

onConnected

public void onConnected(Channel c)

onConnectFailed

public void onConnectFailed(java.lang.Throwable cause)

onClosed

public void onClosed(Channel c)

getPendingBuffer

protected PendingBuffer getPendingBuffer()

newPendingBuffer

protected abstract PendingBuffer newPendingBuffer()

resetPendingBuffer

protected abstract void resetPendingBuffer(PendingBuffer b)

flushPendingBuffer

protected abstract void flushPendingBuffer(PendingBuffer b,
                                           Channel c)

closePendingBuffer

protected abstract void closePendingBuffer(PendingBuffer b)

startConnection

protected abstract void startConnection()

sendMessageChannel

protected abstract void sendMessageChannel(Channel c,
                                           java.lang.Object msg)

closeChannel

protected abstract void closeChannel(Channel c)