Class NetTxConnection

Namespace

Apache.NMS.ActiveMQ

Assembly

Apache.NMS.ActiveMQ.dll

public sealed class NetTxConnection : Connection, INetTxConnection, IConnection, IDisposable, IStartable, IStoppable

Inheritance

object

Connection

NetTxConnection

Implements

INetTxConnection

IConnection

IDisposable

IStartable

IStoppable

Inherited Members

Connection.Start()

Connection.Stop()

Connection.CreateSession()

Connection.CreateSession(AcknowledgementMode)

Connection.Close()

Connection.Dispose()

Connection.PurgeTempDestinations()

Connection.SyncRequest(Command)

Connection.SyncRequest(Command, TimeSpan)

Connection.Oneway(Command)

Connection.CreateLocalTransactionId()

Connection.CreateTemporaryDestination(bool)

Connection.DeleteTemporaryDestination(IDestination)

Connection.DeleteDestination(IDestination)

Connection.ConsumerTransformer

Connection.ProducerTransformer

Connection.UserName

Connection.Password

Connection.ProtocolVersion

Connection.AsyncSend

Connection.AsyncClose

Connection.SendAcksAsync

Connection.AckMode

Connection.ProducerWindowSize

Connection.AlwaysSyncSend

Connection.CopyMessageOnSend

Connection.UseCompression

Connection.MessagePrioritySupported

Connection.OptimizeAcknowledge

Connection.OptimizeAcknowledgeTimeOut

Connection.OptimizedAckScheduledAckInterval

Connection.UseRetroactiveConsumer

Connection.ExclusiveConsumer

Connection.ConsumerFailoverRedeliveryWaitPeriod

Connection.CheckForDuplicates

Connection.TransactedIndividualAck

Connection.NonBlockingRedelivery

Connection.AuditDepth

Connection.AuditMaximumProducerNumber

Connection.MetaData

Connection.BrokerUri

Connection.ITransport

Connection.TransportFailed

Connection.FirstFailureError

Connection.RequestTimeout

Connection.AcknowledgementMode

Connection.DispatchAsync

Connection.WatchTopicAdvisories

Connection.ClientId

Connection.DefaultClientId

Connection.ConnectionId

Connection.BrokerInfo

Connection.BrokerWireFormat

Connection.ResourceManagerId

Connection.RedeliveryPolicy

Connection.PrefetchPolicy

Connection.CompressionPolicy

Connection.IsStarted

Connection.ExceptionListener

Connection.ConnectionInterruptedListener

Connection.ConnectionResumedListener

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

NetTxConnection(Uri, ITransport, IdGenerator)

public NetTxConnection(Uri connectionUri, ITransport transport, IdGenerator clientIdGenerator)

Parameters

connectionUri Uri

transport ITransport

clientIdGenerator IdGenerator

Properties

ConfiguredResourceManagerId

public Guid ConfiguredResourceManagerId { get; set; }

Property Value

Guid

RecoveryPolicy

public NetTxRecoveryPolicy RecoveryPolicy { get; set; }

Property Value

NetTxRecoveryPolicy

Methods

CreateActiveMQSession(AcknowledgementMode)

protected override Session CreateActiveMQSession(AcknowledgementMode ackMode)

Parameters

ackMode AcknowledgementMode

Returns

Session

CreateNetTxSession()

public INetTxSession CreateNetTxSession()

Returns

INetTxSession

CreateNetTxSession(bool)

public INetTxSession CreateNetTxSession(bool enlistNativeMsDtcResource)

Parameters

enlistNativeMsDtcResource bool

Returns

INetTxSession

CreateNetTxSession(Transaction)

public INetTxSession CreateNetTxSession(Transaction tx)

Parameters

tx Transaction

Returns

INetTxSession

CreateNetTxSession(Transaction, bool)

public INetTxSession CreateNetTxSession(Transaction tx, bool enlistNativeMsDtcResource)

Parameters

tx Transaction

enlistNativeMsDtcResource bool

Returns

INetTxSession