public final class AMQPTransportConstant extends Object
Modifier and Type | Field and Description |
---|---|
static String |
AMQP_CORRELATION_ID |
static String |
AMQP_HEADER |
static String |
AMQP_TRANSPORT_BUFFER_KEY |
static String |
AMQP_TRANSPORT_PREFIX
The transport prefix for AMQP transport.
|
static String |
AMQP_USE_LWPC |
static String |
AMQP_USE_TX |
static int |
CONNECTION_FACTORY_POOL_DEFAULT |
static String |
DEFAULT_CONNECTION_FACTORY_NAME
The default connection factory name.
|
static String |
DEFAULT_CONTENT_TYPE |
static String |
PARAM_CONNECTION_FACTORY_POOL_SIZE
Configure the executor service worker pool size.
|
static String |
PARAM_INITIAL_RE_CONNECTION_DURATION
If a polling task encounter an exception due to some reason(most probably due to broker
outage) the number of milliseconds it should be suspended before next re-try.
|
static String |
PARAM_MAX_RE_CONNECTION_DURATION
The maximum duration to suspend the polling task in case of an error.
|
static String |
PARAM_RE_CONNECTION_PROGRESSION_FACTOR
If the polling task fails again after the initial re-connection duration
PARAM_INITIAL_RE_CONNECTION_DURATION
next suspend duration will be calculated using this
(PARAM_RE_CONNECTION_PROGRESSION_FACTOR * PARAM_INITIAL_RE_CONNECTION_DURATION). |
static String |
PARAM_RESPONSE_HANDLING_POOL_SIZE |
static String |
PARAM_SEMAPHORE_TIME_OUT |
static String |
PARAM_WORKER_POOL_SIZE |
static String |
PARAMETER_AMQP_CHANNEL_NUMBER
Use the given channel number if possible.
|
static String |
PARAMETER_BIND_EXCHANGE
The name of the exchange that the publisher/consumer should publish/consume message to.
|
static String |
PARAMETER_BINDING_KEYS
The comma separated binding keys this queue should be bound into exchange.
|
static String |
PARAMETER_BROKER_LIST
The list of broker of the form, host1:port1,host2:port2...
|
static String |
PARAMETER_CHANNEL_PREFETCH_COUNT
The channel prefetch count for fair dispatch
|
static String |
PARAMETER_CHANNEL_PREFETCH_SIZE
The channel pre fetch size for fair dispatch
|
static String |
PARAMETER_CHANNEL_QOS_GLOBAL
Should the configuration be used in globally ?
|
static String |
PARAMETER_CONFIGURED_CONTENT_TYPE
Configure the content type as a service parameter
|
static String |
PARAMETER_CONNECTION_FACTORY_NAME
The connection factory to be used either with consumer or producer.
|
static String |
PARAMETER_CONNECTION_URI
The parameter to specify the Uri of the form amqp://userName:password@hostName:portNumber/virtualHost.
|
static String |
PARAMETER_CONSUMER_TX
Use transactions at consumer side if set to true.
|
static String |
PARAMETER_DISPATCHING_TASK_SIZE
Number of dispatching task to use any request messages to actual processing task.
|
static String |
PARAMETER_EXCHANGE_INTERNAL
Should the exchange be declared as internal? One of true of false.
|
static String |
PARAMETER_EXCHANGE_IS_AUTO_DELETE
Should the exchange be deleted if it is no longer in use
|
static String |
PARAMETER_EXCHANGE_IS_DURABLE
The durability of the exchange.
|
static String |
PARAMETER_EXCHANGE_NAME
The name of the exchange to be used.
|
static String |
PARAMETER_EXCHANGE_TYPE
The type of the exchange.
|
static String |
PARAMETER_NO_OF_CONCURRENT_CONSUMERS
Number of concurrent consumers per polling task.
|
static String |
PARAMETER_OPERATE_ON_BLOCKING_MODE
True if the polling task should wait until the she processed the accepted message.
|
static String |
PARAMETER_PUBLISHER_IMMEDIATE_PUBLISH
True if requesting an immediate publishing.
|
static String |
PARAMETER_PUBLISHER_MANDATORY_PUBLISH
True if requesting a mandatory publishing.
|
static String |
PARAMETER_QUEUE_AUTO_DELETE
True if the queue should be auto deleted
|
static String |
PARAMETER_QUEUE_DURABLE
True if the queue is durable
|
static String |
PARAMETER_QUEUE_NAME
The name of the queue
|
static String |
PARAMETER_QUEUE_RESTRICTED
True of the queue is restricted(only within this connection)
|
static String |
PARAMETER_RESPONSE_CONNECTION_FACTORY_NAME
In a two-way scenario which connection factory of the senders' should be used to send
the response
|
static String |
PARAMETER_ROUTING_KEY
The routing key to be used by the publisher
|
static String |
PARAMETER_SCHEDULED_TASK_DELAY
The delay(in milliseconds) that the polling task should delay before next attempt.
|
static String |
PARAMETER_SCHEDULED_TASK_INITIAL_DELAY
The initial delay(in milliseconds) that the polling task should delay before initial attempt.
|
static String |
PARAMETER_SCHEDULED_TASK_TIME_UNIT
The time unit which should use to calculate,
PARAMETER_SCHEDULED_TASK_INITIAL_DELAY and
PARAMETER_SCHEDULED_TASK_DELAY . |
static String |
PROPERTY_AMQP_APP_ID
Message context property to set the AMQP app id.
|
static String |
PROPERTY_AMQP_CLUSTER_ID
Message context property to set the AMQP cluster id.
|
static String |
PROPERTY_AMQP_CONTENT_ENCODING
Message context property to set the AMQP message encoding.
|
static String |
PROPERTY_AMQP_CONTENT_TYPE
Message context property to set the AMQP message content type.
|
static String |
PROPERTY_AMQP_CORRELATION_ID
Message context property to set the AMQP message correlation id.
|
static String |
PROPERTY_AMQP_DELIVER_MODE
Message context property to set the AMQP message delivery mode.
|
static String |
PROPERTY_AMQP_EXPIRATION
Message context property to set the AMQP expiration.
|
static String |
PROPERTY_AMQP_MESSAGE_ID
Message context property to set the message id of the AMQP message.
|
static String |
PROPERTY_AMQP_PRIORITY
Message context property to set the AMQP message priority.
|
static String |
PROPERTY_AMQP_REPLY_TO
Message context property to set the AMQP message reply to header.
|
static String |
PROPERTY_AMQP_TIME_STAMP
Message context property to set the timestamp of the AMQP message.
|
static String |
PROPERTY_AMQP_TYPE
Message context property to set the type of the AMQP message.
|
static String |
PROPERTY_AMQP_USER_ID
Message context property to set the AMQP user id.
|
static String |
PROPERTY_PRODUCER_TX
Use transactions at producer side, possible values are lwpc(light weight publisher confirm),
tx(transaction).
|
static String |
RESPONSE_CONNECTION_FACTORY_NAME |
static int |
RESPONSE_HANDLING_POOL_DEFAULT |
static String |
ROUTING_KEY_DELIMITER |
static int |
WORKER_POOL_DEFAULT |
Constructor and Description |
---|
AMQPTransportConstant() |
public static final String AMQP_TRANSPORT_PREFIX
public static final String DEFAULT_CONNECTION_FACTORY_NAME
public static final String PARAMETER_CONNECTION_URI
public static final String PARAMETER_BROKER_LIST
public static final String PARAMETER_EXCHANGE_NAME
public static final String PARAMETER_EXCHANGE_IS_DURABLE
public static final String PARAMETER_EXCHANGE_IS_AUTO_DELETE
public static final String PARAMETER_CHANNEL_PREFETCH_SIZE
public static final String PARAMETER_CHANNEL_PREFETCH_COUNT
public static final String PARAMETER_CHANNEL_QOS_GLOBAL
public static final String PARAMETER_EXCHANGE_TYPE
public static final String PARAMETER_EXCHANGE_INTERNAL
public static final String PARAMETER_BIND_EXCHANGE
public static final String PARAMETER_BINDING_KEYS
public static final String PARAMETER_ROUTING_KEY
public static final String PARAMETER_PUBLISHER_MANDATORY_PUBLISH
public static final String PARAMETER_PUBLISHER_IMMEDIATE_PUBLISH
public static final String PARAMETER_CONSUMER_TX
public static final String PROPERTY_PRODUCER_TX
public static final String PARAMETER_QUEUE_NAME
public static final String PARAMETER_QUEUE_DURABLE
public static final String PARAMETER_QUEUE_RESTRICTED
public static final String PARAMETER_QUEUE_AUTO_DELETE
public static final String PARAMETER_OPERATE_ON_BLOCKING_MODE
public static final String PARAM_INITIAL_RE_CONNECTION_DURATION
public static final String PARAM_RE_CONNECTION_PROGRESSION_FACTOR
PARAM_INITIAL_RE_CONNECTION_DURATION
next suspend duration will be calculated using this
(PARAM_RE_CONNECTION_PROGRESSION_FACTOR * PARAM_INITIAL_RE_CONNECTION_DURATION).public static final String PARAM_MAX_RE_CONNECTION_DURATION
public static final String PARAMETER_CONNECTION_FACTORY_NAME
public static final String PARAMETER_RESPONSE_CONNECTION_FACTORY_NAME
public static final String PARAMETER_SCHEDULED_TASK_INITIAL_DELAY
public static final String PARAMETER_SCHEDULED_TASK_DELAY
public static final String PARAMETER_SCHEDULED_TASK_TIME_UNIT
PARAMETER_SCHEDULED_TASK_INITIAL_DELAY
and
PARAMETER_SCHEDULED_TASK_DELAY
.public static final String PARAMETER_NO_OF_CONCURRENT_CONSUMERS
public static final String PARAMETER_DISPATCHING_TASK_SIZE
public static final String PARAMETER_AMQP_CHANNEL_NUMBER
public static final String PARAMETER_CONFIGURED_CONTENT_TYPE
public static final String PROPERTY_AMQP_CONTENT_TYPE
public static final String PROPERTY_AMQP_CONTENT_ENCODING
public static final String AMQP_HEADER
public static final String PROPERTY_AMQP_DELIVER_MODE
public static final String PROPERTY_AMQP_PRIORITY
public static final String PROPERTY_AMQP_CORRELATION_ID
public static final String PROPERTY_AMQP_REPLY_TO
public static final String PROPERTY_AMQP_EXPIRATION
public static final String PROPERTY_AMQP_MESSAGE_ID
public static final String PROPERTY_AMQP_TIME_STAMP
public static final String PROPERTY_AMQP_TYPE
public static final String PROPERTY_AMQP_USER_ID
public static final String PROPERTY_AMQP_APP_ID
public static final String PROPERTY_AMQP_CLUSTER_ID
public static final String PARAM_CONNECTION_FACTORY_POOL_SIZE
public static final int CONNECTION_FACTORY_POOL_DEFAULT
public static final String PARAM_RESPONSE_HANDLING_POOL_SIZE
public static final int RESPONSE_HANDLING_POOL_DEFAULT
public static final String PARAM_WORKER_POOL_SIZE
public static final int WORKER_POOL_DEFAULT
public static final String PARAM_SEMAPHORE_TIME_OUT
public static final String AMQP_CORRELATION_ID
public static final String AMQP_TRANSPORT_BUFFER_KEY
public static final String AMQP_USE_TX
public static final String AMQP_USE_LWPC
public static final String DEFAULT_CONTENT_TYPE
public static final String ROUTING_KEY_DELIMITER
public static final String RESPONSE_CONNECTION_FACTORY_NAME
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.