本文整理汇总了Java中com.ib.client.EClientSocket类的典型用法代码示例。如果您正苦于以下问题：Java EClientSocket类的具体用法？Java EClientSocket怎么用？Java EClientSocket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
EClientSocket类属于com.ib.client包，在下文中一共展示了EClientSocket类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getIBSocket
import com.ib.client.EClientSocket; //导入依赖的package包/类
public static IBSocket getIBSocket(IBConnectionInfo info) {
synchronized (connectionMap) {
IBSocket savedSocket = connectionMap.get(info);
if (savedSocket == null) {
IBConnection connection = new IBConnection();
connection.setClientId(info.getClientId());
connection.setHost(info.getHost());
connection.setPort(info.getPort());
EClientSocket clientSocket = new EClientSocket(connection);
savedSocket = new IBSocket(connection, clientSocket);
connectionMap.put(info, savedSocket);
}
return savedSocket;
}
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:22，代码来源:IBConnectionRegistry.java
示例2: testTickPrice
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testTickPrice() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final int tickerId = 1;
final int field = 2;
final double price = 1.23;
final int canAutoExecute = 1;
final Ticker ticker = new StockTicker("LUT");
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
//
// ibQuoteEngine.idToTickerMap.put(tickerId, ticker);
// ibQuoteEngine.tickPrice(tickerId, field, price, canAutoExecute);
// Level1QuoteData quote = ibQuoteEngine.level1QuoteQueue.take();
// assertEquals( ticker, quote.getTicker() );
// assertEquals( field, quote.getField() );
// assertEquals( price, quote.getPrice(), 0 );
// assertEquals( canAutoExecute, quote.getCanAutoExecute() );
// assertEquals( 0, quote.getSize());
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:27，代码来源:IBQuoteEngineTest.java
示例3: testTickSize_NullTicker
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testTickSize_NullTicker() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final int tickerId = 1;
final int field = 99;
final int size = 5;
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
//
// ibQuoteEngine.tickSize(tickerId, field, size);
// assertEquals( 0, ibQuoteEngine.level1QuoteQueue.size() );
//
//
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:21，代码来源:IBQuoteEngineTest.java
示例4: testOverloadedTickPrice
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testOverloadedTickPrice() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final int tickerId = 1;
final int field = 99;
final int size = 5;
final int canAutoExecute = 1;
final double price = 4.00;
Ticker ticker = new StockTicker("ABC");
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// ibQuoteEngine.idToTickerMap.put(tickerId, ticker);
// ibQuoteEngine.tickPrice(tickerId, field, price , 1);
// assertEquals( 1, ibQuoteEngine.level1QuoteQueue.size() );
// Level1QuoteData data = ibQuoteEngine.level1QuoteQueue.take();
// assertEquals( canAutoExecute, data.getCanAutoExecute() );
// assertEquals( field, data.getField());
// assertEquals( price, data.getPrice(), 0 );
// assertEquals( 0, data.getSize() );
// assertEquals( ticker, data.getTicker());
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:27，代码来源:IBQuoteEngineTest.java
示例5: testErrorException
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testErrorException() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
Exception e = new Exception("Bogus Exception");
int id = 1;
int code = 1;
String message = "foo";
QuoteError quoteError = new QuoteError(id, code, message);
//
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// ibQuoteEngine.error( id, code, message );
// assertEquals( quoteError, ibQuoteEngine.quoteErrorQueue.take() );
// assertEquals( 0, ibQuoteEngine.quoteErrorQueue.size() );
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:21，代码来源:IBQuoteEngineTest.java
示例6: testErrorString
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testErrorString() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final String errorString = "Bogus Error";
QuoteError quoteError = new QuoteError(errorString);
//
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// ibQuoteEngine.error( errorString );
// assertEquals( quoteError, ibQuoteEngine.quoteErrorQueue.take() );
// assertEquals( 0, ibQuoteEngine.quoteErrorQueue.size() );
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:17，代码来源:IBQuoteEngineTest.java
示例7: testErrorCode_Exception
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testErrorCode_Exception() throws Exception {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final int id = 1;
final int errorCode = 2;
Exception ex = new IllegalAccessException();
QuoteError quoteError = new QuoteError(ex);
//
// IBQuoteEngine ibQuoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// ibQuoteEngine.error( ex );
// assertEquals( quoteError, ibQuoteEngine.quoteErrorQueue.take() );
// assertEquals( 0, ibQuoteEngine.quoteErrorQueue.size() );
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:21，代码来源:IBQuoteEngineTest.java
示例8: testSubscribeLevel1_alreadySubscribed
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testSubscribeLevel1_alreadySubscribed() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final Level1QuoteListener mockQuoteListener = mockery.mock(Level1QuoteListener.class);
final Ticker ticker = new StockTicker("LUT");
final int requestId = 1;
final Contract contract = ContractBuilderFactory.getContractBuilder(ticker).buildContract(ticker);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// quoteEngine.tickerMap.put(ticker, requestId);
// quoteEngine.subscribeLevel1(ticker, mockQuoteListener);
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:19，代码来源:IBQuoteEngineTest.java
示例9: testUnsubscribeLevel1_NoRequestIdFound
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testUnsubscribeLevel1_NoRequestIdFound() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final Level1QuoteListener mockQuoteListener = mockery.mock(Level1QuoteListener.class);
final Ticker ticker = new StockTicker("LUT");
final int requestId = 1;
final Contract contract = ContractBuilderFactory.getContractBuilder(ticker).buildContract(ticker);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// quoteEngine.unsubscribeLevel1(ticker, mockQuoteListener);
//
// assertNull( quoteEngine.tickerMap.get(ticker) );
// assertNull( quoteEngine.idToTickerMap.get( requestId ) );
//
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:20，代码来源:IBQuoteEngineTest.java
示例10: testUnsubscribeLevel1_EmptyListenerList
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testUnsubscribeLevel1_EmptyListenerList() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
final Level1QuoteListener mockQuoteListener = mockery.mock(Level1QuoteListener.class);
final Ticker ticker = new StockTicker("LUT");
final int requestId = 1;
final Contract contract = ContractBuilderFactory.getContractBuilder(ticker).buildContract(ticker);
//
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// quoteEngine.getLevel1ListenerMap().put(ticker, new ArrayList<Level1QuoteListener>() );
// quoteEngine.tickerMap.put(ticker, requestId);
// quoteEngine.unsubscribeLevel1(ticker, mockQuoteListener);
//
// assertNull( quoteEngine.tickerMap.get(ticker) );
// assertNull( quoteEngine.idToTickerMap.get( requestId ) );
//
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:24，代码来源:IBQuoteEngineTest.java
示例11: testGetServerTime
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testGetServerTime() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// try {
// quoteEngine.getServerTime();
// fail();
// } catch( UnsupportedOperationException ex ) {
// //this should happen
// }
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:19，代码来源:IBQuoteEngineTest.java
示例12: testStartEngine
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testStartEngine() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// try {
// quoteEngine.startEngine(null);
// fail();
// } catch( UnsupportedOperationException ex ) {
// //this should happen
// }
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:19，代码来源:IBQuoteEngineTest.java
示例13: testStartEngine_NoArgs
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testStartEngine_NoArgs() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// quoteEngine.startEngine();
// assertTrue( quoteEngine.level1QuoteProcessor.isRunning() );
// assertTrue( quoteEngine.level2QuoteProcessor.isRunning() );
// assertTrue( quoteEngine.errorQuoteProcessor.isRunning() );
//
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:17，代码来源:IBQuoteEngineTest.java
示例14: testStopEngine
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Test
@Ignore
public void testStopEngine() {
final EClientSocket mockSocketInterface = mockery.mock(EClientSocket.class);
final IBConnectionInterface mockConnectionInterface = mockery.mock(IBConnectionInterface.class);
// IBQuoteEngine quoteEngine = new IBQuoteEngine(mockSocketInterface, mockConnectionInterface);
// try {
// quoteEngine.stopEngine();
// fail();
// } catch( UnsupportedOperationException ex ) {
// //this should happen
// }
// mockery.assertIsSatisfied();
fail();
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:19，代码来源:IBQuoteEngineTest.java
示例15: setUp
import com.ib.client.EClientSocket; //导入依赖的package包/类
@Before
public void setUp() {
mockIbSocket = mock(IBSocket.class);
mockConnectionInterface = mock(IBConnectionInterface.class);
mockClientSocketInterface = mock(EClientSocket.class);
mockOrderEventQueue = mock(BlockingQueue.class);
when(mockIbSocket.getClientSocket()).thenReturn(mockClientSocketInterface);
when(mockIbSocket.getConnection()).thenReturn(mockConnectionInterface);
InteractiveBrokersBroker.logger = mockLogger;
broker = new InteractiveBrokersBroker(mockIbSocket);
broker.orderEventQueue = mockOrderEventQueue;
}
开发者ID:rterp，项目名称:SumZeroTrading，代码行数:17，代码来源:InteractiveBrokersBrokerTest.java
示例16: OcaSample
import com.ib.client.EClientSocket; //导入依赖的package包/类
private static void OcaSample(EClientSocket client, int nextOrderId) {
//OCA order
//! [ocasubmit]
List<Order> OcaOrders = new ArrayList<Order>();
OcaOrders.add(OrderSamples.LimitOrder("BUY", 1, 10));
OcaOrders.add(OrderSamples.LimitOrder("BUY", 1, 11));
OcaOrders.add(OrderSamples.LimitOrder("BUY", 1, 12));
OcaOrders = OrderSamples.OneCancelsAll("TestOCA_" + nextOrderId, OcaOrders, 2);
for (Order o : OcaOrders) {
client.placeOrder(nextOrderId++, ContractSamples.USStock(), o);
}
//! [ocasubmit]
}
开发者ID:qerio，项目名称:goib，代码行数:17，代码来源:Testbed.java
示例17: historicalDataRequests
import com.ib.client.EClientSocket; //导入依赖的package包/类
private static void historicalDataRequests(EClientSocket client) throws InterruptedException {
/*** Requesting historical data ***/
//! [reqhistoricaldata]
Calendar cal = Calendar.getInstance();
cal.add(Calendar.MONTH, -6);
SimpleDateFormat form = new SimpleDateFormat("yyyyMMdd HH:mm:ss");
String formatted = form.format(cal.getTime());
client.reqHistoricalData(4001, ContractSamples.EurGbpFx(), formatted, "1 M", "1 day", "MIDPOINT", 1, 1, null);
client.reqHistoricalData(4002, ContractSamples.EuropeanStock(), formatted, "10 D", "1 min", "TRADES", 1, 1, null);
Thread.sleep(2000);
/*** Canceling historical data requests ***/
client.cancelHistoricalData(4001);
client.cancelHistoricalData(4002);
//! [reqhistoricaldata]
}
开发者ID:qerio，项目名称:goib，代码行数:18，代码来源:Testbed.java
示例18: conditionSamples
import com.ib.client.EClientSocket; //导入依赖的package包/类
private static void conditionSamples(EClientSocket client, int nextOrderId) {
//! [order_conditioning_activate]
Order mkt = OrderSamples.MarketOrder("BUY", 100);
//Order will become active if conditioning criteria is met
mkt.conditionsCancelOrder(true);
mkt.conditions().add(OrderSamples.PriceCondition(208813720, "SMART", 600, false, false));
mkt.conditions().add(OrderSamples.ExecutionCondition("EUR.USD", "CASH", "IDEALPRO", true));
mkt.conditions().add(OrderSamples.MarginCondition(30, true, false));
mkt.conditions().add(OrderSamples.PercentageChangeCondition(15.0, 208813720, "SMART", true, true));
mkt.conditions().add(OrderSamples.TimeCondition("20160118 23:59:59", true, false));
mkt.conditions().add(OrderSamples.VolumeCondition(208813720, "SMART", false, 100, true));
client.placeOrder(nextOrderId++, ContractSamples.EuropeanStock(), mkt);
//! [order_conditioning_activate]
//Conditions can make the order active or cancel it. Only LMT orders can be conditionally canceled.
//! [order_conditioning_cancel]
Order lmt = OrderSamples.LimitOrder("BUY", 100, 20);
//The active order will be cancelled if conditioning criteria is met
lmt.conditionsCancelOrder(true);
lmt.conditions().add(OrderSamples.PriceCondition(208813720, "SMART", 600, false, false));
client.placeOrder(nextOrderId++, ContractSamples.EuropeanStock(), lmt);
//! [order_conditioning_cancel]
}
开发者ID:qerio，项目名称:goib，代码行数:26，代码来源:Testbed.java
示例19: hedgeSample
import com.ib.client.EClientSocket; //导入依赖的package包/类
private static void hedgeSample(EClientSocket client, int nextOrderId) throws InterruptedException {
//F Hedge order
//! [hedgesubmit]
//Parent order on a contract which currency differs from your base currency
Order parent = OrderSamples.LimitOrder("BUY", 100, 10);
parent.orderId(nextOrderId++);
//Hedge on the currency conversion
Order hedge = OrderSamples.MarketFHedge(parent.orderId(), "BUY");
//Place the parent first...
client.placeOrder(parent.orderId(), ContractSamples.EuropeanStock(), parent);
//Then the hedge order
client.placeOrder(nextOrderId++, ContractSamples.EurGbpFx(), hedge);
//! [hedgesubmit]
}
开发者ID:qerio，项目名称:goib，代码行数:17，代码来源:Testbed.java
示例20: reutersFundamentals
import com.ib.client.EClientSocket; //导入依赖的package包/类
private static void reutersFundamentals(EClientSocket client) throws InterruptedException {
//! [reqfundamentaldata]
client.reqFundamentalData(8001, ContractSamples.USStock(), "ReportsFinSummary");
//! [reqfundamentaldata]
Thread.sleep(2000);
//! [fundamentalexamples]
client.reqFundamentalData(8002, ContractSamples.USStock(), "ReportSnapshot"); //for company overview
client.reqFundamentalData(8003, ContractSamples.USStock(), "ReportRatios"); //for financial ratios
client.reqFundamentalData(8004, ContractSamples.USStock(), "ReportsFinStatements"); //for financial statements
client.reqFundamentalData(8005, ContractSamples.USStock(), "RESC"); //for analyst estimates
client.reqFundamentalData(8006, ContractSamples.USStock(), "CalendarReport"); //for company calendar
//! [fundamentalexamples]
//! [cancelfundamentaldata]
client.cancelFundamentalData(8001);
//! [cancelfundamentaldata]
}
开发者ID:qerio，项目名称:goib，代码行数:22，代码来源:Testbed.java
注：本文中的com.ib.client.EClientSocket类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论