Package com.bank.trading.data

Class ReferenceData

java.lang.Object

com.bank.trading.data.ReferenceData

All Implemented Interfaces:

Runnable

public class ReferenceData
extends Object
implements Runnable

This service takes market data from bloomberg and stream to lamport service. This service is run as a cluster with one active leader, the others on standby in case of failure.

Constructor Summary

Constructors

Constructor	Description
ReferenceData(InetSocketAddress address, URI bloombergURI, InetSocketAddress LamportAddress, List<InetSocketAddress> peers)	Constructor to initialize the market data service.

Method Summary

Modifier and Type	Method	Description
void	addReferenceData(String ReferenceData)	Add market data to the system.
void	changeLamportAddress(InetSocketAddress address)	Change the lamport address to a new one.
void	run()	This method is responsible for streaming data from bloomberg to lamport service.
void	sendReferenceData(Event ReferenceData)	Send market data to the lamport service.

Methods inherited from class java.lang.Object

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

Constructor Details

ReferenceData

public ReferenceData(InetSocketAddress address,
 URI bloombergURI,
 InetSocketAddress LamportAddress,
 List<InetSocketAddress> peers)

Constructor to initialize the market data service.

Parameters:

address - the address of this service.

bloombergURI - the URI of the bloomberg service.

LamportAddress - the address of the lamport service.

Method Details

run

public void run()

This method is responsible for streaming data from bloomberg to lamport service.

Specified by:

run in interface Runnable

changeLamportAddress

public void changeLamportAddress(InetSocketAddress address)

Change the lamport address to a new one. This is called when the lamport leader changes.

Parameters:

address - the new lamport address.

addReferenceData

public void addReferenceData(String ReferenceData)

Add market data to the system.

Parameters:

ReferenceData - the market data to be added.

sendReferenceData

public void sendReferenceData(Event ReferenceData)

Send market data to the lamport service. This will be called to send the latest market data.

Parameters:

ReferenceData - the market data event to be sent.