Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel 클래스 참조

더 자세히 ...

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에 대한 상속 다이어그램 :

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에 대한 협력 다이어그램:

Public 멤버 함수
	RabbitMqClientChannel (IModel channel)
void	ExchangeDeclare (string exchange, string type, bool durable, bool autoDelete)
void	QueueDeclare (string queue, bool durable, bool exclusive, bool autoDelete)
void	QueueBind (string queue, string exchange, string routingKey)
IRabbitMqBasicProperties	CreateBasicProperties ()
void	BasicPublish (string exchange, string routingKey, bool mandatory, IRabbitMqBasicProperties properties, ReadOnlyMemory< byte > body)
string	BasicConsume (string queue, bool autoAck, Func< RabbitMqDelivery, CancellationToken, Task > onReceived)
void	BasicAck (ulong deliveryTag, bool multiple)
void	BasicNack (ulong deliveryTag, bool multiple, bool requeue)
void	BasicReject (ulong deliveryTag, bool requeue)
void	BasicCancel (string consumerTag)
void	Close ()
void	Dispose ()

속성
bool	IsOpen [get]

Private 속성
readonly IModel	_channel

상세한 설명

Rabbit Mq Client Channel 기능과 관련 상태를 캡슐화합니다.

RabbitMqClientConnectionFactory.cs 파일의 173 번째 라인에서 정의되었습니다.

생성자 & 소멸자 문서화

RabbitMqClientChannel()

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.RabbitMqClientChannel ( IModel channel )

inline

실제 RabbitMQ 채널 모델을 감싸는 어댑터를 초기화합니다.

매개변수

channel

감쌀 실제 채널입니다.

RabbitMqClientConnectionFactory.cs 파일의 201 번째 라인에서 정의되었습니다.

        {
            _channel = channel;
        }

다음을 참조함 : _channel.

멤버 함수 문서화

BasicAck()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicAck ( ulong deliveryTag, bool multiple )

inline

Basic Ack 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
multiple	multiple에 사용할 bool 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 520 번째 라인에서 정의되었습니다.

        {
            _channel.BasicAck(deliveryTag, multiple);
        }

다음을 참조함 : _channel.

BasicCancel()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicCancel ( string consumerTag )

inline

Basic Cancel 작업을 수행합니다.

매개변수

consumerTag

consumer Tag에 사용할 string 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 607 번째 라인에서 정의되었습니다.

        {
            _channel.BasicCancel(consumerTag);
        }

다음을 참조함 : _channel.

BasicConsume()

string Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicConsume ( string queue, bool autoAck, Func< RabbitMqDelivery, CancellationToken, Task > onReceived )

inline

Basic Consume 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
autoAck	auto Ack에 사용할 bool 값입니다.
onReceived	on Received에 사용할 Func<RabbitMqDelivery, CancellationToken, Task> 값입니다.

반환값

Basic Consume 작업에서 생성한 string 결과입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 481 번째 라인에서 정의되었습니다.

        {
            var consumer = new AsyncEventingBasicConsumer(_channel);
            consumer.Received += async (_, args) =>
            {
                var delivery = new RabbitMqDelivery(args.DeliveryTag, args.RoutingKey, args.Body);
                await onReceived(delivery, CancellationToken.None).ConfigureAwait(false);
            };
 
            return _channel.BasicConsume(queue, autoAck, consumer);
        }

다음을 참조함 : _channel.

BasicNack()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicNack ( ulong deliveryTag, bool multiple, bool requeue )

inline

Basic Nack 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
multiple	multiple에 사용할 bool 값입니다.
requeue	requeue에 사용할 bool 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 557 번째 라인에서 정의되었습니다.

        {
            _channel.BasicNack(deliveryTag, multiple, requeue);
        }

다음을 참조함 : _channel.

BasicPublish()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicPublish ( string exchange, string routingKey, bool mandatory, IRabbitMqBasicProperties properties, ReadOnlyMemory< byte > body )

inline

Basic Publish 작업을 수행합니다.

매개변수

exchange	exchange에 사용할 string 값입니다.
routingKey	routing Key에 사용할 string 값입니다.
mandatory	mandatory에 사용할 bool 값입니다.
properties	properties에 사용할 IRabbitMqBasicProperties 값입니다.
body	body에 사용할 ReadOnlyMemory<byte> 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 423 번째 라인에서 정의되었습니다.

        {
            var clientProperties = properties is RabbitMqClientBasicProperties wrapped
                ? wrapped.Inner
                : _channel.CreateBasicProperties();
 
            clientProperties.Persistent = properties.Persistent;
            clientProperties.ContentType = properties.ContentType;
            clientProperties.Type = properties.Type;
 
            _channel.BasicPublish(exchange, routingKey, mandatory, clientProperties, body);
        }

다음을 참조함 : _channel, Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqBasicProperties.ContentType, Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqBasicProperties.Persistent, Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqBasicProperties.Type.

BasicReject()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.BasicReject ( ulong deliveryTag, bool requeue )

inline

Basic Reject 작업을 수행합니다.

매개변수

deliveryTag	delivery Tag에 사용할 ulong 값입니다.
requeue	requeue에 사용할 bool 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 586 번째 라인에서 정의되었습니다.

        {
            _channel.BasicReject(deliveryTag, requeue);
        }

다음을 참조함 : _channel.

Close()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.Close ( )

inline

Close 작업을 수행합니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 620 번째 라인에서 정의되었습니다.

        {
            _channel.Close();
        }

다음을 참조함 : _channel.

CreateBasicProperties()

IRabbitMqBasicProperties Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.CreateBasicProperties ( )

inline

Basic Properties 값을 생성합니다.

반환값

Create Basic Properties 작업에서 생성한 IRabbitMqBasicProperties 결과입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 370 번째 라인에서 정의되었습니다.

        {
            return new RabbitMqClientBasicProperties(_channel.CreateBasicProperties());
        }

다음을 참조함 : _channel.

Dispose()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.Dispose ( )

inline

실제 채널 리소스를 해제합니다.

RabbitMqClientConnectionFactory.cs 파일의 633 번째 라인에서 정의되었습니다.

        {
            _channel.Dispose();
        }

다음을 참조함 : _channel.

ExchangeDeclare()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.ExchangeDeclare ( string exchange, string type, bool durable, bool autoDelete )

inline

Exchange Declare 작업을 수행합니다.

매개변수

exchange	exchange에 사용할 string 값입니다.
type	type에 사용할 string 값입니다.
durable	durable에 사용할 bool 값입니다.
autoDelete	auto Delete에 사용할 bool 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 256 번째 라인에서 정의되었습니다.

        {
            _channel.ExchangeDeclare(exchange, type, durable, autoDelete, arguments: null);
        }

다음을 참조함 : _channel.

QueueBind()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.QueueBind ( string queue, string exchange, string routingKey )

inline

Queue Bind 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
exchange	exchange에 사용할 string 값입니다.
routingKey	routing Key에 사용할 string 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 346 번째 라인에서 정의되었습니다.

        {
            _channel.QueueBind(queue, exchange, routingKey);
        }

다음을 참조함 : _channel.

QueueDeclare()

void Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.QueueDeclare ( string queue, bool durable, bool exclusive, bool autoDelete )

inline

Queue Declare 작업을 수행합니다.

매개변수

queue	queue에 사용할 string 값입니다.
durable	durable에 사용할 bool 값입니다.
exclusive	exclusive에 사용할 bool 값입니다.
autoDelete	auto Delete에 사용할 bool 값입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 305 번째 라인에서 정의되었습니다.

        {
            _channel.QueueDeclare(queue, durable, exclusive, autoDelete, arguments: null);
        }

다음을 참조함 : _channel.

멤버 데이터 문서화

_channel

readonly IModel Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel._channel

private

channel 값을 보관합니다.

RabbitMqClientConnectionFactory.cs 파일의 183 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : BasicAck(), BasicCancel(), BasicConsume(), BasicNack(), BasicPublish(), BasicReject(), Close(), CreateBasicProperties(), Dispose(), ExchangeDeclare(), QueueBind(), QueueDeclare(), RabbitMqClientChannel().

속성 문서화

IsOpen

bool Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel.IsOpen

get

실제 채널이 열려 있는지 여부를 가져옵니다.

Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel를 구현.

RabbitMqClientConnectionFactory.cs 파일의 214 번째 라인에서 정의되었습니다.

---

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

• RabbitMqClientConnectionFactory.cs