![]() Public static void HttpConsumer(this IPipeConfigurator configurator, IPipe receivePipe, HttpHostSettings settings, Supervisor, managementPipe, sendEndpointProvider, publishEndpointProvider, host) Var pipeBuilderConfigurator = new RabbitMqConsumerPipeSpecification(pipe, settings, receiveObserver, transportObserver, exchangeBindings, Public static void RabbitMqConsumer(this IPipeConfigurator configurator, IPipe pipe, ReceiveSettings settings, IReceiveObserver receiveObserver, IReceiveTransportObserver transportObserver, IEnumerable exchangeBindings, ITaskSupervisor supervisor, IManagementPipe managementPipe, ISendEndpointProvider sendEndpointProvider, IPublishEndpointProvider publishEndpointProvider, IRabbitMqHost host) Var pipeBuilderConfigurator = new RabbitMqConsumerPipeSpecification(pipe, settings, receiveObserver, endpointObserver, exchangeBindings, taskSupervisor, mediator) Ĭonfigurator.AddPipeSpecification(pipeBuilderConfigurator) Throw new ArgumentNullException(nameof(configurator)) Public static void RabbitMqConsumer(this IPipeConfigurator configurator, IPipe pipe, ReceiveSettings settings, IReceiveObserver receiveObserver, IReceiveEndpointObserver endpointObserver, IEnumerable exchangeBindings, ITaskSupervisor taskSupervisor, Mediator mediator) / Adds a RabbitMQ Basic Consumer to the pipeline MessageConsumer.Listener += HandleMessage _deliver圜omplete = new TaskCompletionSource () _receiveSettings = session.GetPayload () _tracker = new DeliveryTracker(HandleDeliver圜omplete) _deadLetterTransport = deadLetterTransport IDeadLetterTransport deadLetterTransport, IErrorTransport errorTransport) IReceiveObserver receiveObserver, ActiveMqReceiveEndpointContext context, Public ActiveMqBasicConsumer(SessionContext session, IMessageConsumer messageConsumer, Uri inputAddress, IPipe receivePipe, / The receive pipe to dispatch messages / The input address for messages received by the consumer / The basic consumer receives messages pushed from the broker. ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |