public class EBSPriceFeed extends Object implements OutgoingFIXTransport, BinaryFASTListener
Constructor and Description |
---|
EBSPriceFeed(InputStream template,
String host,
int port,
String sender,
String vendor) |
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(MsgBuf buf) |
void |
waitUntilReadyToWrite() |
void |
write(byte[] message) |
int |
write(byte[] message,
int offset,
int length) |
int |
write(ByteBuffer buf,
int offset,
int length) |
public EBSPriceFeed(InputStream template, String host, int port, String sender, String vendor) throws IOException
IOException
public byte[] readMessage() throws IOException
IOException
public boolean isBlockingSocket()
isBlockingSocket
in interface FIXTransport
public void readMessage(MsgBuf buf) throws IOException
readMessage
in interface FIXTransport
IOException
public void write(byte[] message) throws IOException
write
in interface FIXTransport
IOException
public int write(byte[] message, int offset, int length) throws IOException
write
in interface FIXTransport
IOException
public int write(ByteBuffer buf, int offset, int length) throws IOException
write
in interface FIXTransport
IOException
public void waitUntilReadyToWrite() throws IOException
waitUntilReadyToWrite
in interface FIXTransport
IOException
public void open() throws IOException
open
in interface OutgoingFIXTransport
IOException
public void close() throws IOException
close
in interface FIXTransport
IOException
public int getOptimalBufferSize()
getOptimalBufferSize
in interface FIXTransport
public String getAddress()
getAddress
in interface FIXTransport
public void onMessage(IFastMessage message)
BinaryFASTListener
onMessage
in interface BinaryFASTListener
message
- FIX Messages.Copyright © 2000-2017 EPAM Systems. All Rights Reserved.