com.epam.fixengine.session

Class AbstractFIXSession.ConsumingControlTransportWrapper

java.lang.Object

com.epam.fixengine.session.AbstractFIXSession.ConsumingControlTransportWrapper

All Implemented Interfaces:

FIXTransport

Enclosing class:

AbstractFIXSession

public class AbstractFIXSession.ConsumingControlTransportWrapper
extends Object
implements FIXTransport

Method Summary

Modifier and Type	Method and Description
void	close() Close transport method.
String	getAddress()
int	getOptimalBufferSize() Gets optimal the size of buffer.
void	handle(int toWrite, int written, long begin, long end)
boolean	isBlockingSocket()
void	readMessage(MsgBuf buf) Read message method.
void	setRawTags(RawFIXUtil.RawTags rawTags)
void	waitUntilReadyToWrite()
void	write(byte[] message) Write message method.
int	write(byte[] message, int offset, int length) Write message method.
int	write(ByteBuffer buf, int offset, int length)

Methods inherited from class java.lang.Object

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

Method Detail

isBlockingSocket

public boolean isBlockingSocket()

Specified by:

isBlockingSocket in interface FIXTransport

readMessage

public void readMessage(MsgBuf buf)
                 throws IOException

Description copied from interface: FIXTransport

Read message method.

Specified by:

readMessage in interface FIXTransport

Throws:

IOException - - if error occurred

write

public void write(byte[] message)
           throws IOException

Description copied from interface: FIXTransport

Write message method.

Specified by:

write in interface FIXTransport

Parameters:

message - the message

Throws:

IOException - - if error occurred

waitUntilReadyToWrite

public void waitUntilReadyToWrite()
                           throws IOException

Specified by:

waitUntilReadyToWrite in interface FIXTransport

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: FIXTransport

Close transport method.

Specified by:

close in interface FIXTransport

Throws:

IOException - - if error occurred

setRawTags

public void setRawTags(RawFIXUtil.RawTags rawTags)

Specified by:

setRawTags in interface FIXTransport

getOptimalBufferSize

public int getOptimalBufferSize()

Description copied from interface: FIXTransport

Gets optimal the size of buffer.

Specified by:

getOptimalBufferSize in interface FIXTransport

Returns:

the buffer size in bytes

getAddress

public String getAddress()

Specified by:

getAddress in interface FIXTransport

write

public int write(byte[] message,
                 int offset,
                 int length)
          throws IOException

Description copied from interface: FIXTransport

Write message method.

Specified by:

write in interface FIXTransport

Parameters:

message - the message

offset - the start buffer position

length - the length

Throws:

IOException - - if error occurred

write

public int write(ByteBuffer buf,
                 int offset,
                 int length)
          throws IOException

Specified by:

write in interface FIXTransport

Throws:

IOException

handle

public void handle(int toWrite,
                   int written,
                   long begin,
                   long end)