Class ConnectionFactory

Namespace

Apache.NMS.ActiveMQ

Assembly

Apache.NMS.ActiveMQ.dll

public class ConnectionFactory : IConnectionFactory

Inheritance

object

ConnectionFactory

Implements

IConnectionFactory

Derived

NetTxConnectionFactory

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConnectionFactory()

public ConnectionFactory()

ConnectionFactory(string)

public ConnectionFactory(string brokerUri)

Parameters

brokerUri string

ConnectionFactory(string, string)

public ConnectionFactory(string brokerUri, string clientID)

Parameters

brokerUri string

clientID string

ConnectionFactory(Uri)

public ConnectionFactory(Uri brokerUri)

Parameters

brokerUri Uri

ConnectionFactory(Uri, string)

public ConnectionFactory(Uri brokerUri, string clientID)

Parameters

brokerUri Uri

clientID string

Fields

DEFAULT_BROKER_URL

public const string DEFAULT_BROKER_URL = "failover:tcp://localhost:61616"

Field Value

string

ENV_BROKER_URL

public const string ENV_BROKER_URL = "ACTIVEMQ_BROKER_URL"

Field Value

string

Properties

AckMode

public string AckMode { set; }

Property Value

string

AcknowledgementMode

public AcknowledgementMode AcknowledgementMode { get; set; }

Property Value

AcknowledgementMode

AlwaysSyncSend

public bool AlwaysSyncSend { get; set; }

Property Value

bool

AsyncClose

public bool AsyncClose { get; set; }

Property Value

bool

AsyncSend

public bool AsyncSend { get; set; }

Property Value

bool

AuditDepth

public int AuditDepth { get; set; }

Property Value

int

AuditMaximumProducerNumber

public int AuditMaximumProducerNumber { get; set; }

Property Value

int

BrokerUri

public Uri BrokerUri { get; set; }

Property Value

Uri

CheckForDuplicates

public bool CheckForDuplicates { get; set; }

Property Value

bool

ClientId

public string ClientId { get; set; }

Property Value

string

ClientIdGenerator

public IdGenerator ClientIdGenerator { get; set; }

Property Value

IdGenerator

ClientIdPrefix

public string ClientIdPrefix { get; set; }

Property Value

string

CompressionPolicy

public ICompressionPolicy CompressionPolicy { get; set; }

Property Value

ICompressionPolicy

ConsumerFailoverRedeliveryWaitPeriod

public long ConsumerFailoverRedeliveryWaitPeriod { get; set; }

Property Value

long

ConsumerTransformer

public ConsumerTransformerDelegate ConsumerTransformer { get; set; }

Property Value

ConsumerTransformerDelegate

CopyMessageOnSend

public bool CopyMessageOnSend { get; set; }

Property Value

bool

DispatchAsync

public bool DispatchAsync { get; set; }

Property Value

bool

ExclusiveConsumer

public bool ExclusiveConsumer { get; set; }

Property Value

bool

MessagePrioritySupported

public bool MessagePrioritySupported { get; set; }

Property Value

bool

NonBlockingRedelivery

public bool NonBlockingRedelivery { get; set; }

Property Value

bool

OptimizeAcknowledge

public bool OptimizeAcknowledge { get; set; }

Property Value

bool

OptimizeAcknowledgeTimeOut

public long OptimizeAcknowledgeTimeOut { get; set; }

Property Value

long

OptimizedAckScheduledAckInterval

public long OptimizedAckScheduledAckInterval { get; set; }

Property Value

long

Password

public string Password { get; set; }

Property Value

string

PrefetchPolicy

public PrefetchPolicy PrefetchPolicy { get; set; }

Property Value

PrefetchPolicy

ProducerTransformer

public ProducerTransformerDelegate ProducerTransformer { get; set; }

Property Value

ProducerTransformerDelegate

ProducerWindowSize

public int ProducerWindowSize { get; set; }

Property Value

int

RedeliveryPolicy

public IRedeliveryPolicy RedeliveryPolicy { get; set; }

Property Value

IRedeliveryPolicy

RequestTimeout

public int RequestTimeout { get; set; }

Property Value

int

SendAcksAsync

public bool SendAcksAsync { get; set; }

Property Value

bool

TransactedIndividualAck

public bool TransactedIndividualAck { get; set; }

Property Value

bool

UseCompression

public bool UseCompression { get; set; }

Property Value

bool

UseRetroactiveConsumer

public bool UseRetroactiveConsumer { get; set; }

Property Value

bool

UserName

public string UserName { get; set; }

Property Value

string

WatchTopicAdvisories

public bool WatchTopicAdvisories { get; set; }

Property Value

bool

Methods

ConfigureConnection(Connection)

protected virtual void ConfigureConnection(Connection connection)

Parameters

connection Connection

CreateActiveMQConnection()

protected virtual Connection CreateActiveMQConnection()

Returns

Connection

CreateActiveMQConnection(ITransport)

protected virtual Connection CreateActiveMQConnection(ITransport transport)

Parameters

transport ITransport

Returns

Connection

CreateActiveMQConnection(string, string)

protected virtual Connection CreateActiveMQConnection(string userName, string password)

Parameters

userName string

password string

Returns

Connection

CreateConnection()

public IConnection CreateConnection()

Returns

IConnection

CreateConnection(string, string)

public IConnection CreateConnection(string userName, string password)

Parameters

userName string

password string

Returns

IConnection

ExceptionHandler(Exception)

protected static void ExceptionHandler(Exception ex)

Parameters

ex Exception

GetDefaultBrokerUrl()

public static string GetDefaultBrokerUrl()

Returns

string

Events

OnException

public event ExceptionListener OnException

Event Type

ExceptionListener