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

[범례]

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

Public 멤버 함수
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 ()

속성
bool	IsOpen `[get]`

상세한 설명

메시지 버스가 토폴로지, 발행, 소비 및 확인에 사용하는 최소 RabbitMQ 채널 계약입니다.

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

멤버 함수 문서화

◆ BasicAck()

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

배달 메시지의 성공 처리를 확인합니다.

매개변수

deliveryTag	확인할 배달 태그입니다.
multiple	이전 태그까지 함께 확인할지 여부입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ BasicCancel()

void Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel.BasicCancel ( string consumerTag )

지정한 소비자를 취소합니다.

매개변수

consumerTag 취소할 소비자 태그입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ BasicConsume()

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

Queue의 배달 메시지를 처리하는 비동기 소비자를 시작합니다.

매개변수

queue	소비할 Queue입니다.
autoAck	자동 확인 여부입니다.
onReceived	배달 메시지를 처리할 비동기 콜백입니다.

반환값: 생성된 소비자 태그입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ BasicNack()

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

배달 메시지의 처리 실패를 확인합니다.

매개변수

deliveryTag	실패 확인할 배달 태그입니다.
multiple	이전 태그까지 함께 처리할지 여부입니다.
requeue	메시지를 Queue에 다시 넣을지 여부입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ BasicPublish()

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

메시지 본문과 속성을 지정한 Exchange 및 라우팅 키로 발행합니다.

매개변수

exchange	대상 Exchange입니다.
routingKey	발행 라우팅 키입니다.
mandatory	라우팅 실패 시 반환을 요구할지 여부입니다.
properties	메시지 속성입니다.
body	발행할 메시지 본문입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ BasicReject()

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

단일 배달 메시지를 거부합니다.

매개변수

deliveryTag	거부할 배달 태그입니다.
requeue	메시지를 Queue에 다시 넣을지 여부입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ Close()

void Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel.Close ( )

RabbitMQ 채널을 닫습니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ CreateBasicProperties()

IRabbitMqBasicProperties Dreamine.Communication.RabbitMQ.Infrastructure.IRabbitMqChannel.CreateBasicProperties ( )

발행 작업에 사용할 새 메시지 속성을 생성합니다.

반환값: 채널에 연결된 메시지 속성입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

◆ ExchangeDeclare()

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

지정한 형식과 수명 설정으로 Exchange를 선언합니다.

매개변수

exchange	Exchange 이름입니다.
type	Exchange 형식입니다.
durable	영속 선언 여부입니다.
autoDelete	미사용 시 자동 삭제 여부입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

다음에 의해서 참조됨 : Dreamine.Communication.RabbitMQ.Buses.RabbitMqMessageBus.DeclareTopology().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ QueueBind()

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

라우팅 키로 Queue를 Exchange에 바인딩합니다.

매개변수

queue	바인딩할 Queue 이름입니다.
exchange	대상 Exchange 이름입니다.
routingKey	바인딩 라우팅 키입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

다음에 의해서 참조됨 : Dreamine.Communication.RabbitMQ.Buses.RabbitMqMessageBus.DeclareTopology().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ QueueDeclare()

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

지정한 수명 및 소유권 설정으로 Queue를 선언합니다.

매개변수

queue	Queue 이름입니다.
durable	영속 선언 여부입니다.
exclusive	현재 연결 전용 여부입니다.
autoDelete	미사용 시 자동 삭제 여부입니다.

Dreamine.Communication.RabbitMQ.Infrastructure.RabbitMqClientConnectionFactory.RabbitMqClientChannel에서 구현되었습니다.

다음에 의해서 참조됨 : Dreamine.Communication.RabbitMQ.Buses.RabbitMqMessageBus.DeclareTopology().

이 함수를 호출하는 함수들에 대한 그래프입니다.: