com.epam.ebsfast

Class EBSPriceFeed

java.lang.Object

com.epam.ebsfast.EBSPriceFeed

All Implemented Interfaces:

BinaryFASTListener, com.epam.fixengine.transport.FIXTransport, com.epam.fixengine.transport.OutgoingFIXTransport

public class EBSPriceFeed
extends Object
implements com.epam.fixengine.transport.OutgoingFIXTransport, BinaryFASTListener

Constructor Summary

Constructors

Constructor and Description
EBSPriceFeed(InputStream template, String host, int port, String sender, String vendor)

Method Summary

Modifier and Type	Method and Description
void	close()
String	getAddress()
int	getOptimalBufferSize()
boolean	isBlockingSocket()
void	onMessage(IFastMessage message) Listens FIX messages.
void	open()
byte[]	readMessage()
void	readMessage(com.epam.fix.message.MsgBuf buf)
void	setRawTags(com.epam.fix.message.RawFIXUtil.RawTags rawTags)
void	waitUntilReadyToWrite()
void	write(byte[] message)
int	write(byte[] message, int offset, int length)
int	write(com.epam.common.utils.ByteBuffer buf, int offset, int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

EBSPriceFeed

public EBSPriceFeed(InputStream template,
                    String host,
                    int port,
                    String sender,
                    String vendor)
             throws IOException

Throws:

IOException

Method Detail

readMessage

public byte[] readMessage()
                   throws IOException

Throws:

IOException

isBlockingSocket

public boolean isBlockingSocket()

Specified by:

isBlockingSocket in interface com.epam.fixengine.transport.FIXTransport

readMessage

public void readMessage(com.epam.fix.message.MsgBuf buf)
                 throws IOException

Specified by:

readMessage in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

write

public void write(byte[] message)
           throws IOException

Specified by:

write in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

write

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

Specified by:

write in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

write

public int write(com.epam.common.utils.ByteBuffer buf,
                 int offset,
                 int length)
          throws IOException

Specified by:

write in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

waitUntilReadyToWrite

public void waitUntilReadyToWrite()
                           throws IOException

Specified by:

waitUntilReadyToWrite in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

open

public void open()
          throws IOException

Specified by:

open in interface com.epam.fixengine.transport.OutgoingFIXTransport

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface com.epam.fixengine.transport.FIXTransport

Throws:

IOException

getOptimalBufferSize

public int getOptimalBufferSize()

Specified by:

getOptimalBufferSize in interface com.epam.fixengine.transport.FIXTransport

getAddress

public String getAddress()

Specified by:

getAddress in interface com.epam.fixengine.transport.FIXTransport

setRawTags

public void setRawTags(com.epam.fix.message.RawFIXUtil.RawTags rawTags)

Specified by:

setRawTags in interface com.epam.fixengine.transport.FIXTransport

onMessage

public void onMessage(IFastMessage message)

Description copied from interface: BinaryFASTListener

Listens FIX messages.

Specified by:

onMessage in interface BinaryFASTListener

Parameters:

message - FIX Messages.