Distributed Queue System

This project is a simple implementation of a distributed queue system in Java. It demonstrates the basic concepts of message brokering, producing, and consuming messages using custom classes.

Project Structure

• Main.java: Entry point of the application.
• model/Message.java: Defines the message structure.
• Service/Broker.java: Handles message brokering between producers and consumers.
• Service/Producer.java: Produces messages and sends them to the broker.
• Service/Consumer.java: Consumes messages from the broker.

Getting Started

Prerequisites

• Java 8 or higher
• Maven (for building the project)

Build and Run

1. Clone the repository:

   git clone https://github.com/kd123/DistributedQueue.git
   cd DistributedQueue

2. Build the project using Maven:

   mvn clean install

3. Run the application:

   mvn exec:java -Dexec.mainClass="com.que.Main"

Usage

• The application demonstrates how producers can send messages to a broker, and consumers can receive messages from the broker.
• You can extend the functionality by adding more producers, consumers, or enhancing the broker logic.

Contributing

Pull requests are welcome. For major changes, please open an issue first to discuss what you would like to change.