Reactive Java client for the MT Access API.

MT Access

MT Access is a service that allows easy access to MT4 server the most known Forex trading plaform. If you are interested, please contact

Installation

Releases

 repositories {
jCenter()
}
dependencies {
implementation 'lv.sergluka.mt-access:mt-access:<latest-version>'
}

Snapshots

See the snapshots list here

 repositories {
maven { url 'https://oss.jfrog.org/artifactory/oss-snapshot-local' }
}
dependencies {
implementation 'lv.sergluka.mt-access:mt-access:x.x.x-SNAPSHOT'
}

Details

Client is written on Java 8 based on Project Reactor

Examples

Blocking connect / disconnect

importcom.finplant.mt_access.MtAccessClient;
varparams = MtAccessClient.ConnectionParameters.builder()
.uri(URI.create("wss://localhost:8080"))
.server("127.0.0.1")
.login(1)
.password("password")
.build();
MtAccessClientclient = MtAccessClient.createSecure(params,
BaseSpecification.classLoader.getResourceAsStream("keystore.jks"),
"keystore password", true);
MonoProcessorblockingProcessor = MonoProcessor.create();
connectionDisposable = client.connection().subscribe({ blockingProcessor.onNext(true) })
blockingProcessor.timeout(Duration.ofSeconds(30)).block();
System.out.format("Connected\n");
connectionDisposable.dispose();
System.out.format("Disconnected\n");

Reconnect on connection lost

client.connection()
.doOnError(e -> System.err.format("Connection lost: %s", e.getMessage()))
.retryBackoff(10, Duration.ofSeconds(1))
.subscribe(none -> System.out.println("Connected"),
Throwable::printStackTrace,
() -> System.out.println("Connection closed"));

Create new user

Mt4UserRecorduser1 = Mt4UserRecord.builder()
.login(100)
.enable(true)
.group("demoforex")
.enableChangePassword(true)
.readOnly(false)
.enableOtp(false)
.passwordPhone("PhonePass")
.name("Johans Smits")
.country("Latvia")
.city("Riga")
.state("n/a")
.zipcode("LV-1063")
.address("Maskavas 322 - 501")
.leadSource("Source")
.phone("+37100112233")
.email("sergey.lukashevich@finplant.com")
.comment("User comment")
.id("id1")
.status("STATUS")
.leverage(1000)
.agentAccount(1)
.taxes(BigDecimal.valueOf(30.33))
.sendReports(false)
.mqid(123456)
.userColor(0xFF00FFL)
.apiData(newbyte[0])
.password("Pass1")
.passwordInvestor("Pass2")
.build();
varnewLogin = client.users().add(user1).timeout(Duration.ofSeconds(3)).block();
System.out.format("New user login is %d\n", newLogin);

Get user by login

varuser = client.users().get(100).timeout(Duration.ofSeconds(30)).block();
System.out.format("User: %s\n", user);

Tick feed subscription

client.symbols().show("EURUSD").block();
client.market().listen().take(10).subscribe(
tick -> { System.out.format("Tick: %s\n", tick); },
Throwable::printStackTrace,
() -> client.symbols().hide("EURUSD").subscribe());

Trading request confirmation with a new price

client.dealing().listen().subscribe(request -> {
client.dealing().confirm(request.getId(),
BigDecimal.valueOf(2.11), BigDecimal.valueOf(2.12),
DealingProcedures.ConfirmMode.NORMAL)
.subscribe(none -> System.out.println("Request is confirmed"),
e -> System.err.println("Cannot confirm request: " + e.getMessage()));
});

See more samples in tests