fila-client (Java)

Java client SDK for the Fila message broker.

Installation

Gradle

implementation 'dev.faisca:fila-client:0.1.0'

Maven

<dependency>
<groupId>dev.faisca</groupId>
<artifactId>fila-client</artifactId>
<version>0.1.0</version>
</dependency>

Usage

importdev.faisca.fila.*;
importjava.util.Map;
try (FilaClientclient = FilaClient.builder("localhost:5555").build()) {
// Enqueue a messageStringmsgId = client.enqueue("my-queue", Map.of("tenant", "acme"), "hello".getBytes());
System.out.println("Enqueued: " + msgId);
// Consume messagesConsumerHandlehandle = client.consume("my-queue", msg -> {
System.out.println("Received: " + newString(msg.getPayload()));
client.ack("my-queue", msg.getId());
});
// ... do other work ...// Stop consuminghandle.cancel();
}

TLS

System trust store (public CAs)

If the Fila server uses a certificate issued by a public CA (e.g., Let's Encrypt), enable TLS with the JVM's default trust store:

try (FilaClientclient = FilaClient.builder("localhost:5555")
.withTls()
.build()) {
// use client...
}

Custom CA certificate

For servers using self-signed or private CA certificates, provide the CA cert explicitly:

byte[] caCert = Files.readAllBytes(Path.of("ca.pem"));
try (FilaClientclient = FilaClient.builder("localhost:5555")
.withTlsCaCert(caCert)
.build()) {
// use client...
}

Mutual TLS (mTLS)

For mutual TLS, also provide the client certificate and key. This works with both trust modes:

byte[] caCert = Files.readAllBytes(Path.of("ca.pem"));
byte[] clientCert = Files.readAllBytes(Path.of("client.pem"));
byte[] clientKey = Files.readAllBytes(Path.of("client-key.pem"));
try (FilaClientclient = FilaClient.builder("localhost:5555")
.withTlsCaCert(caCert)
.withTlsClientCert(clientCert, clientKey)
.build()) {
// use client...
}

API Key Authentication

When the server has auth enabled, provide an API key:

try (FilaClientclient = FilaClient.builder("localhost:5555")
.withApiKey("your-api-key")
.build()) {
// use client...
}

The key is sent as a Bearer token in the authorization metadata header on every RPC.

TLS and API key auth can be combined:

try (FilaClientclient = FilaClient.builder("localhost:5555")
.withTlsCaCert(caCert)
.withTlsClientCert(clientCert, clientKey)
.withApiKey("your-api-key")
.build()) {
// use client...
}

API Reference

FilaClient

Create a client with the builder:

FilaClientclient = FilaClient.builder("localhost:5555").build();

FilaClient implements AutoCloseable for use with try-with-resources.

Builder Methods

Method	Description
withTls()	Enable TLS using JVM's default trust store (cacerts)
withTlsCaCert(byte[] caCertPem)	CA certificate for TLS server verification (implies withTls())
withTlsClientCert(byte[] certPem, byte[] keyPem)	Client cert + key for mTLS
withApiKey(String apiKey)	API key sent as Bearer token on every RPC

All builder methods are optional. When none are set, the client connects over plaintext without authentication (backward compatible).

enqueue(String queue, Map<String, String> headers, byte[] payload) -> String

Enqueue a message. Returns the broker-assigned message ID (UUIDv7).

Throws QueueNotFoundException if the queue does not exist.

consume(String queue, Consumer<ConsumeMessage> handler) -> ConsumerHandle

Start consuming messages from a queue. Messages are delivered to the handler on a background thread. Nacked messages are redelivered on the same stream.

Call handle.cancel() to stop consuming.

Throws QueueNotFoundException if the queue does not exist.

ack(String queue, String msgId)

Acknowledge a successfully processed message.

Throws MessageNotFoundException if the message does not exist.

nack(String queue, String msgId, String error)

Negatively acknowledge a message. The message is requeued based on the queue's configuration.

Throws MessageNotFoundException if the message does not exist.

ConsumeMessage

Method	Type	Description
getId()	String	Broker-assigned message ID (UUIDv7)
getHeaders()	Map<String, String>	Message headers
getPayload()	byte[]	Message payload
getFairnessKey()	String	Fairness key assigned by the broker
getAttemptCount()	int	Number of delivery attempts
getQueue()	String	Queue this message belongs to

Error Handling

All exceptions extend FilaException (unchecked):

• QueueNotFoundException — queue does not exist
• MessageNotFoundException — message does not exist (or already acked)
• RpcException — unexpected gRPC failure (includes status code via getCode())

try {
client.enqueue("missing-queue", Map.of(), "data".getBytes());
} catch (QueueNotFoundExceptione) {
System.err.println("Queue not found: " + e.getMessage());
}

License

AGPLv3 — see LICENSE.