org.gytheio.messaging.amqp

Class AmqpNodeBootstrapUtils

java.lang.Object

org.gytheio.messaging.amqp.AmqpNodeBootstrapUtils

public class AmqpNodeBootstrapUtils
extends Object

A utility class for helping to bootstrap AMQP nodes from command line arguments

Author:

Ray Gauss II

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROP_MESSAGING_BROKER_PASSWORD
static String	PROP_MESSAGING_BROKER_URL
static String	PROP_MESSAGING_BROKER_USERNAME
static String	PROP_MESSAGING_QUEUE_REPLY
static String	PROP_MESSAGING_QUEUE_REQUEST

Constructor Summary

Constructors

Constructor and Description
AmqpNodeBootstrapUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static AmqpDirectEndpoint	createEndpoint(org.gytheio.messaging.MessageConsumer messageConsumer, Properties properties)
static AmqpDirectEndpoint	createEndpoint(org.gytheio.messaging.MessageConsumer messageConsumer, String brokerUrl, String brokerUsername, String brokerPassword, String requestQueueName, String replyQueueName) Creates an AMQP endpoint (sender and receiver) from the given arguments
static void	validate(String brokerUrl, String requestQueueName, String replyQueueName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROP_MESSAGING_BROKER_URL

public static final String PROP_MESSAGING_BROKER_URL

See Also:

Constant Field Values

PROP_MESSAGING_BROKER_USERNAME

public static final String PROP_MESSAGING_BROKER_USERNAME

See Also:

Constant Field Values

PROP_MESSAGING_BROKER_PASSWORD

public static final String PROP_MESSAGING_BROKER_PASSWORD

See Also:

Constant Field Values

PROP_MESSAGING_QUEUE_REQUEST

public static final String PROP_MESSAGING_QUEUE_REQUEST

See Also:

Constant Field Values

PROP_MESSAGING_QUEUE_REPLY

public static final String PROP_MESSAGING_QUEUE_REPLY

See Also:

Constant Field Values

Constructor Detail

AmqpNodeBootstrapUtils

public AmqpNodeBootstrapUtils()

Method Detail

createEndpoint

public static AmqpDirectEndpoint createEndpoint(org.gytheio.messaging.MessageConsumer messageConsumer,
                                String brokerUrl,
                                String brokerUsername,
                                String brokerPassword,
                                String requestQueueName,
                                String replyQueueName)

Creates an AMQP endpoint (sender and receiver) from the given arguments

Parameters:

messageConsumer - the processor received messages are sent to

args -

Returns:

createEndpoint

public static AmqpDirectEndpoint createEndpoint(org.gytheio.messaging.MessageConsumer messageConsumer,
                                Properties properties)

validate

public static void validate(String brokerUrl,
            String requestQueueName,
            String replyQueueName)