public class RabbitMqUtils extends Object implements RabbitMqConstants
APPSENSOR_ADD_ATTACK_QUEUE, APPSENSOR_ADD_EVENT_QUEUE, APPSENSOR_CLIENT_APPLICATION_NAME, APPSENSOR_EXCHANGE_NAME, APPSENSOR_GET_RESPONSES_QUEUE_PREFIX, APPSENSOR_GET_RESPONSES_QUEUE_SUFFIX, RABBITMQ_HOST_ENV_VAR_NAME, RABBITMQ_PASSWORD_ENV_VAR_NAME, RABBITMQ_PORT_ENV_VAR_NAME, RABBITMQ_USERNAME_ENV_VAR_NAME
Constructor and Description |
---|
RabbitMqUtils() |
Modifier and Type | Method and Description |
---|---|
static String |
buildResponseQueueName(String clientApplicationName) |
static com.rabbitmq.client.Connection |
createConnection(org.springframework.core.env.Environment environment) |
static void |
sendMessage(String message,
Collection<String> queueNames,
org.springframework.core.env.Environment environment) |
public static com.rabbitmq.client.Connection createConnection(org.springframework.core.env.Environment environment) throws IOException
public static void sendMessage(String message, Collection<String> queueNames, org.springframework.core.env.Environment environment) throws IOException
Copyright © 2016 The Open Web Application Security Project (OWASP). All rights reserved.