Class Connection

Namespace

Apache.NMS.ActiveMQ

Assembly

Apache.NMS.ActiveMQ.dll

public class Connection : IConnection, IDisposable, IStartable, IStoppable

Inheritance

object

Connection

Implements

IConnection

IDisposable

IStartable

IStoppable

Derived

NetTxConnection

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

Connection(Uri, ITransport, IdGenerator)

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

Parameters

connectionUri Uri

transport ITransport

clientIdGenerator IdGenerator

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

BrokerInfo

public BrokerInfo BrokerInfo { get; }

Property Value

BrokerInfo

BrokerUri

public Uri BrokerUri { get; }

Property Value

Uri

BrokerWireFormat

public WireFormatInfo BrokerWireFormat { get; }

Property Value

WireFormatInfo

CheckForDuplicates

public bool CheckForDuplicates { get; set; }

Property Value

bool

ClientId

public string ClientId { get; set; }

Property Value

string

CompressionPolicy

public ICompressionPolicy CompressionPolicy { get; set; }

Property Value

ICompressionPolicy

ConnectionId

public ConnectionId ConnectionId { get; }

Property Value

ConnectionId

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

DefaultClientId

public string DefaultClientId { set; }

Property Value

string

DispatchAsync

public bool DispatchAsync { get; set; }

Property Value

bool

ExclusiveConsumer

public bool ExclusiveConsumer { get; set; }

Property Value

bool

FirstFailureError

public Exception FirstFailureError { get; }

Property Value

Exception

ITransport

public ITransport ITransport { get; set; }

Property Value

ITransport

IsStarted

public bool IsStarted { get; }

Property Value

bool

MessagePrioritySupported

public bool MessagePrioritySupported { get; set; }

Property Value

bool

MetaData

public IConnectionMetaData MetaData { get; }

Property Value

IConnectionMetaData

NextSessionId

protected SessionId NextSessionId { get; }

Property Value

SessionId

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

ProtocolVersion

public int ProtocolVersion { get; }

Property Value

int

RedeliveryPolicy

public IRedeliveryPolicy RedeliveryPolicy { get; set; }

Property Value

IRedeliveryPolicy

RequestTimeout

public TimeSpan RequestTimeout { get; set; }

Property Value

TimeSpan

ResourceManagerId

public string ResourceManagerId { get; }

Property Value

string

SendAcksAsync

public bool SendAcksAsync { get; set; }

Property Value

bool

TransactedIndividualAck

public bool TransactedIndividualAck { get; set; }

Property Value

bool

TransportFailed

public bool TransportFailed { get; }

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

CheckClosed()

protected void CheckClosed()

CheckClosedOrFailed()

protected void CheckClosedOrFailed()

Close()

public void Close()

CreateActiveMQSession(AcknowledgementMode)

protected virtual Session CreateActiveMQSession(AcknowledgementMode ackMode)

Parameters

ackMode AcknowledgementMode

Returns

Session

CreateLocalTransactionId()

public LocalTransactionId CreateLocalTransactionId()

Returns

LocalTransactionId

CreateSession()

public ISession CreateSession()

Returns

ISession

CreateSession(AcknowledgementMode)

public ISession CreateSession(AcknowledgementMode sessionAcknowledgementMode)

Parameters

sessionAcknowledgementMode AcknowledgementMode

Returns

ISession

CreateTemporaryDestination(bool)

public ActiveMQTempDestination CreateTemporaryDestination(bool topic)

Parameters

topic bool

Returns

ActiveMQTempDestination

DeleteDestination(IDestination)

public void DeleteDestination(IDestination destination)

Parameters

destination IDestination

DeleteTemporaryDestination(IDestination)

public void DeleteTemporaryDestination(IDestination destination)

Parameters

destination IDestination

DispatchMessage(MessageDispatch)

protected void DispatchMessage(MessageDispatch dispatch)

Parameters

dispatch MessageDispatch

Dispose()

public void Dispose()

Dispose(bool)

protected void Dispose(bool disposing)

Parameters

disposing bool

~Connection()

protected ~Connection()

OnCommand(ITransport, Command)

protected void OnCommand(ITransport commandTransport, Command command)

Parameters

commandTransport ITransport

command Command

OnKeepAliveCommand(ITransport, KeepAliveInfo)

protected void OnKeepAliveCommand(ITransport commandTransport, KeepAliveInfo info)

Parameters

commandTransport ITransport

info KeepAliveInfo

OnTransportInterrupted(ITransport)

protected void OnTransportInterrupted(ITransport sender)

Parameters

sender ITransport

OnTransportResumed(ITransport)

protected void OnTransportResumed(ITransport sender)

Parameters

sender ITransport

Oneway(Command)

public void Oneway(Command command)

Parameters

command Command

PurgeTempDestinations()

public void PurgeTempDestinations()

Start()

public void Start()

Stop()

public void Stop()

SyncRequest(Command)

public Response SyncRequest(Command command)

Parameters

command Command

Returns

Response

SyncRequest(Command, TimeSpan)

public Response SyncRequest(Command command, TimeSpan requestTimeout)

Parameters

command Command

requestTimeout TimeSpan

Returns

Response

Events

ConnectionInterruptedListener

public event ConnectionInterruptedListener ConnectionInterruptedListener

Event Type

ConnectionInterruptedListener

ConnectionResumedListener

public event ConnectionResumedListener ConnectionResumedListener

Event Type

ConnectionResumedListener

ExceptionListener

public event ExceptionListener ExceptionListener

Event Type

ExceptionListener