Currently it is only java-bindings for dealer
To build cocaine-framework-java you'll need
- libcocaine-dealer
- ant
cd to cocaine-framework-java directory
and run ant
in cocaine-framework-java
- ./target/jars/yandex-cocaine-dealer.jar
- ./target/lib/lib-cocaine-framework-java.so
packagecocaine.dealer;
importjava.util.concurrent.TimeUnit;
publicclassUsageExample {
publicstaticvoidmain(String[] args) {
StringdealerConfig = "./src/test/resoueces/dealer_config.json";
StringappHandlePath = "myapp/myhandle";
Dealerdealer = null;
byte[] message = "helloworld".getBytes();
MessagePolicymessagePolicy = MessagePolicy.builder()
.maxRetries(10)
.sendToAllHosts()
.timeout(10, TimeUnit.SECONDS)
.deadline(10, TimeUnit.DAYS)
.build();
try {
dealer = newDealer(dealerConfig);
Responseresponse = null;
try {
response = dealer.sendMessage(appHandlePath, message,
messagePolicy);
for (byte[] chunk : response.asIterable(10, TimeUnit.SECONDS)) {
System.out.println(newString(chunk));
}
} finally {
if (response != null) {
response.close();
}
}
} finally {
if (dealer != null)
dealer.close();
}
}
}