CatMQ is a queue server that allows offline data processing. The main purpose of this server is to analyze text snippets and reject those that have offensive terms.

These instructions will get you a copy of the project up and running on your local machine for development and testing purpose.

There are two ways to get started:

cd new-server
make setup
make run

make run

make test

cd new-server
make docker-build
make docker-run

make docker-kill

The server receives TCP connections on port 23023 and follows a message sending and replying protocol. Client connections remain open until the client process is closed. Messages sent to and from the server are messages ending in '\n' with the format specified in Protocol.

To send a message to the queue (publish), the client must send to the server the following message:

{"operation":"PUT","data":"<some data>"}\n

The server responds with:

{"operation":"OK","data":""}\n

In case of error, the server should respond:

{"operation":"ERR","data":"Operation failed!"}\n

To receive a message from the queue, the client must send the following message to the server:

{"operation":"GET","data":""}\n

If there is any message in the queue, the server responds with:

{"operation":"MSG","data":"<some data>"}\n

If the queue is empty, the server responds with:

{"operation":"EMP","data":""}\n

In case of error, the server should respond:

{"operation":"ERR","data":"Operation failed!"}\n

The client library must have a Client class that receives the host and server port and have the following methods:

Connects to the server and leaves a socket open with the server.

Closes the socket opened with the server. Does nothing if the connection already it's closed.

Sends a message to the queue. This method takes the message to be sent as an argument.

Read a message from the queue. If the server responds with EMP, it returns null (no error).

We use Semantic version for versioning. For versions available, see changelog.

Contributions are what make the open source community such an amazing place to learn, inspire, and create. Any contributions you make are greatly appreciated. See contribute policy.

This project is licensed under the MIT License.