Skip to content

Java client

Anton Kropp edited this page Feb 23, 2016 · 10 revisions

This is the official supported client.

Pull back our java client from maven Maven Central

<dependency>
    <groupId>io.paradoxical</groupId>
     <artifactId>cassieq-client</artifactId>
    <version>${cassieq.client.version}</version>
</dependency>

Create a client

CassieqApi client = CassieqApi.createClient(server.getBaseUri().toString(), CassieqCredentials.signedQueryString("..."));

The signed query string can be generated from the admin api

Create a queue

final QueueName queueName = QueueName.valueOf("your-queue");

client.createQueue(testAccountName, new QueueCreateOptions(queueName)).execute();

Put a message into the queue

client.addMessage(AccountName.valueOf("test"), QueueName.valueOf("your-queue"), "message").execute();

Get and ack a message from the queue

final Response<GetMessageResponse> message = client.getMessage(testAccountName, queueName).execute();

final GetMessageResponse body = message.body();

final String popReceipt = body.getPopReceipt();

final Response<ResponseBody> ackResponse = client.ackMessage(testAccountName, queueName, popReceipt).execute();

Clone this wiki locally