org.fusesource.stomp.codec
Class StompProtocolCodec

java.lang.Object
  org.fusesource.stomp.codec.StompProtocolCodec

All Implemented Interfaces:

org.fusesource.hawtdispatch.transport.ProtocolCodec

public class StompProtocolCodec
extends java.lang.Object
implements org.fusesource.hawtdispatch.transport.ProtocolCodec

Author:

Hiram Chirino

Nested Class Summary

Nested classes/interfaces inherited from interface org.fusesource.hawtdispatch.transport.ProtocolCodec

org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState

Constructor Summary

StompProtocolCodec()

Method Summary

org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState	flush()
boolean	full()
long	getLastReadSize()
long	getLastWriteSize()
int	getReadBufferSize()
long	getReadCounter()
int	getWriteBufferSize()
long	getWriteCounter()
boolean	is_empty()
java.lang.Object	read()
void	setReadableByteChannel(java.nio.channels.ReadableByteChannel channel)
void	setWritableByteChannel(java.nio.channels.WritableByteChannel channel)
void	unread(byte[] buffer)
org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState	write(java.lang.Object value)

Methods inherited from class java.lang.Object

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

Constructor Detail

StompProtocolCodec

public StompProtocolCodec()

Method Detail

setWritableByteChannel

public void setWritableByteChannel(java.nio.channels.WritableByteChannel channel)
                            throws java.net.SocketException

Specified by:

setWritableByteChannel in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Throws:

java.net.SocketException

getReadBufferSize

public int getReadBufferSize()

Specified by:

getReadBufferSize in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getWriteBufferSize

public int getWriteBufferSize()

Specified by:

getWriteBufferSize in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

full

public boolean full()

Specified by:

full in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

is_empty

public boolean is_empty()

getWriteCounter

public long getWriteCounter()

Specified by:

getWriteCounter in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getLastWriteSize

public long getLastWriteSize()

Specified by:

getLastWriteSize in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

write

public org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState write(java.lang.Object value)
                                                                      throws java.io.IOException

Specified by:

write in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Throws:

java.io.IOException

flush

public org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState flush()
                                                                      throws java.io.IOException

Specified by:

flush in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Throws:

java.io.IOException

setReadableByteChannel

public void setReadableByteChannel(java.nio.channels.ReadableByteChannel channel)
                            throws java.net.SocketException

Specified by:

setReadableByteChannel in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Throws:

java.net.SocketException

unread

public void unread(byte[] buffer)

Specified by:

unread in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getReadCounter

public long getReadCounter()

Specified by:

getReadCounter in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

getLastReadSize

public long getLastReadSize()

Specified by:

getLastReadSize in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

read

public java.lang.Object read()
                      throws java.io.IOException

Specified by:

read in interface org.fusesource.hawtdispatch.transport.ProtocolCodec

Throws:

java.io.IOException