com.epam.fixengine.transport
Interface FIXTransport

All Known Subinterfaces:

OutgoingFIXTransport

All Known Implementing Classes:

com.epam.fixengine.transport.AbstractFIXTransport, InitiatorFIXTransport

public interface FIXTransport

FIXTransport interface describe base functionality for transport implementation.

Method Summary

void	close() Close transport method.
int	getOptimalBufferSize() Gets optimal the size of buffer.
boolean	isBlockingSocket()
void	readMessage(MsgBuf buf) Read message method.
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)

Method Detail

isBlockingSocket

boolean isBlockingSocket()

readMessage

void readMessage(MsgBuf buf)
                 throws IOException

Read message method.

Throws:

IOException - - if error occurred

write

void write(byte[] message)
           throws IOException

Write message method.

Parameters:

message - the message

Throws:

IOException - - if error occurred

write

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

Write message method.

Parameters:

message - the message

offset - the start buffer position

length - the length

Throws:

IOException - - if error occurred

write

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

Throws:

IOException

waitUntilReadyToWrite

void waitUntilReadyToWrite()
                           throws IOException

Throws:

IOException

close

void close()
           throws IOException

Close transport method.

Throws:

IOException - - if error occurred

getOptimalBufferSize

int getOptimalBufferSize()

Gets optimal the size of buffer.

Returns:

the buffer size in bytes