Features

Installation

<dependency>    <groupId>exchange.core2</groupId>    <artifactId>exchange-core</artifactId>    <version>0.5.3</version></dependency>

Usage examples

// simple async events handlerSimpleEventsProcessoreventsProcessor =newSimpleEventsProcessor(newIEventsHandler() {@OverridepublicvoidtradeEvent(TradeEventtradeEvent) {System.out.println("Trade event: " +tradeEvent);    }@OverridepublicvoidreduceEvent(ReduceEventreduceEvent) {System.out.println("Reduce event: " +reduceEvent);    }@OverridepublicvoidrejectEvent(RejectEventrejectEvent) {System.out.println("Reject event: " +rejectEvent);    }@OverridepublicvoidcommandResult(ApiCommandResultcommandResult) {System.out.println("Command result: " +commandResult);    }@OverridepublicvoidorderBook(OrderBookorderBook) {System.out.println("OrderBook event: " +orderBook);    }});// default exchange configurationExchangeConfigurationconf =ExchangeConfiguration.defaultBuilder().build();// no serializationSupplier<ISerializationProcessor>serializationProcessorFactory = () ->DummySerializationProcessor.INSTANCE;// build exchange coreExchangeCoreexchangeCore =ExchangeCore.builder()        .resultsConsumer(eventsProcessor)        .serializationProcessorFactory(serializationProcessorFactory)        .exchangeConfiguration(conf)        .build();// start up disruptor threadsexchangeCore.startup();// get exchange API for publishing commandsExchangeApiapi =exchangeCore.getApi();

// currency code constantsfinalintcurrencyCodeXbt =11;finalintcurrencyCodeLtc =15;// symbol constantsfinalintsymbolXbtLtc =241;// create symbol specification and publish itCoreSymbolSpecificationsymbolSpecXbtLtc =CoreSymbolSpecification.builder()        .symbolId(symbolXbtLtc)// symbol id        .type(SymbolType.CURRENCY_EXCHANGE_PAIR)        .baseCurrency(currencyCodeXbt)// base = satoshi (1E-8)        .quoteCurrency(currencyCodeLtc)// quote = litoshi (1E-8)        .baseScaleK(1_000_000L)// 1 lot = 1M satoshi (0.01 BTC)        .quoteScaleK(10_000L)// 1 price step = 10K litoshi        .takerFee(1900L)// taker fee 1900 litoshi per 1 lot        .makerFee(700L)// maker fee 700 litoshi per 1 lot        .build();future =api.submitBinaryDataAsync(newBatchAddSymbolsCommand(symbolSpecXbtLtc));

// create user uid=301future =api.submitCommandAsync(ApiAddUser.builder()        .uid(301L)        .build());// create user uid=302future =api.submitCommandAsync(ApiAddUser.builder()        .uid(302L)        .build());

// first user deposits 20 LTCfuture =api.submitCommandAsync(ApiAdjustUserBalance.builder()        .uid(301L)        .currency(currencyCodeLtc)        .amount(2_000_000_000L)        .transactionId(1L)        .build());// second user deposits 0.10 BTCfuture =api.submitCommandAsync(ApiAdjustUserBalance.builder()        .uid(302L)        .currency(currencyCodeXbt)        .amount(10_000_000L)        .transactionId(2L)        .build());

// first user places Good-till-Cancel Bid order// he assumes BTCLTC exchange rate 154 LTC for 1 BTC// bid price for 1 lot (0.01BTC) is 1.54 LTC => 1_5400_0000 litoshi => 10K * 15_400 (in price steps)future =api.submitCommandAsync(ApiPlaceOrder.builder()        .uid(301L)        .orderId(5001L)        .price(15_400L)        .reservePrice(15_600L)// can move bid order up to the 1.56 LTC, without replacing it        .size(12L)// order size is 12 lots        .action(OrderAction.BID)        .orderType(OrderType.GTC)// Good-till-Cancel        .symbol(symbolXbtLtc)        .build());// second user places Immediate-or-Cancel Ask (Sell) order// he assumes wost rate to sell 152.5 LTC for 1 BTCfuture =api.submitCommandAsync(ApiPlaceOrder.builder()        .uid(302L)        .orderId(5002L)        .price(15_250L)        .size(10L)// order size is 10 lots        .action(OrderAction.ASK)        .orderType(OrderType.IOC)// Immediate-or-Cancel        .symbol(symbolXbtLtc)        .build());

future =api.requestOrderBookAsync(symbolXbtLtc,10);

// first user moves remaining order to price 1.53 LTCfuture =api.submitCommandAsync(ApiMoveOrder.builder()        .uid(301L)        .orderId(5001L)        .newPrice(15_300L)        .symbol(symbolXbtLtc)        .build());// first user cancel remaining orderfuture =api.submitCommandAsync(ApiCancelOrder.builder()        .uid(301L)        .orderId(5001L)        .symbol(symbolXbtLtc)        .build());

Future<SingleUserReportResult>report =api.processReport(newSingleUserReportQuery(301),0);

// check fees collectedFuture<TotalCurrencyBalanceReportResult>totalsReport =api.processReport(newTotalCurrencyBalanceReportQuery(),0);System.out.println("LTC fees collected: " +totalsReport.get().getFees().get(currencyCodeLtc));

Testing

TODOs

Contributing

Support