Class NamedQueueSourceSettings

Inheritance
Object
NamedQueueSourceSettings
Inherited Members
Namespace: Akka.Streams.Amqp.RabbitMq
Assembly: Akka.Streams.Amqp.RabbitMq.dll
Syntax
public sealed class NamedQueueSourceSettings : IAmqpSourceSettings, IAmqpConnectorSettings

Properties

| Improve this Doc View Source

AckRequired

Declaration
public bool AckRequired { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

Arguments

Declaration
public IReadOnlyDictionary<string, object> Arguments { get; }
Property Value
Type Description
IReadOnlyDictionary<String, Object>
| Improve this Doc View Source

ConnectionSettings

Declaration
public IAmqpConnectionSettings ConnectionSettings { get; }
Property Value
Type Description
IAmqpConnectionSettings
| Improve this Doc View Source

ConsumerTag

Declaration
public string ConsumerTag { get; }
Property Value
Type Description
String
| Improve this Doc View Source

Declarations

Declaration
public IReadOnlyList<IDeclaration> Declarations { get; }
Property Value
Type Description
IReadOnlyList<IDeclaration>
| Improve this Doc View Source

Exclusive

Declaration
public bool Exclusive { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

NoLocal

Declaration
public bool NoLocal { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

Queue

Declaration
public string Queue { get; }
Property Value
Type Description
String

Methods

| Improve this Doc View Source

Create(IAmqpConnectionSettings, String)

Declaration
public static NamedQueueSourceSettings Create(IAmqpConnectionSettings connectionSettings, string queue)
Parameters
Type Name Description
IAmqpConnectionSettings connectionSettings
String queue
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
String
Overrides
| Improve this Doc View Source

WithAckRequired(Boolean)

Declaration
public NamedQueueSourceSettings WithAckRequired(bool ackRequired)
Parameters
Type Name Description
Boolean ackRequired
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithArguments(KeyValuePair<String, Object>[])

Declaration
public NamedQueueSourceSettings WithArguments(params KeyValuePair<string, object>[] arguments)
Parameters
Type Name Description
KeyValuePair<String, Object>[] arguments
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithArguments(String, Object)

Declaration
public NamedQueueSourceSettings WithArguments(string key, object value)
Parameters
Type Name Description
String key
Object value
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithArguments((String paramName, Object paramValue)[])

Declaration
public NamedQueueSourceSettings WithArguments(params (string paramName, object paramValue)[] arguments)
Parameters
Type Name Description
System.ValueTuple<String, Object>[] arguments
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithConsumerTag(String)

Declaration
public NamedQueueSourceSettings WithConsumerTag(string consumerTag)
Parameters
Type Name Description
String consumerTag
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithDeclarations(IDeclaration[])

Declaration
public NamedQueueSourceSettings WithDeclarations(params IDeclaration[] declarations)
Parameters
Type Name Description
IDeclaration[] declarations
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithExclusive(Boolean)

Declaration
public NamedQueueSourceSettings WithExclusive(bool exclusive)
Parameters
Type Name Description
Boolean exclusive
Returns
Type Description
NamedQueueSourceSettings
| Improve this Doc View Source

WithNoLocal(Boolean)

Declaration
public NamedQueueSourceSettings WithNoLocal(bool noLocal)
Parameters
Type Name Description
Boolean noLocal
Returns
Type Description
NamedQueueSourceSettings

Implements