public class AppSensorClient {
private static final String RABBITMQ_HOST = "localhost";
private static final String RABBITMQ_USERNAME = "guest";
private static final String RABBITMQ_PASSWORD = "guest";
private static final String QUEUE_NAME = "appsensor-queue";
public static void main(String[] args) {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(RABBITMQ_HOST);
factory.setUsername(RABBITMQ_USERNAME);
factory.setPassword(RABBITMQ_PASSWORD);
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Security event occurred!";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
System.out.println("Sent: " + message);
e.printStackTrace();
}
}
}
