ProtonStreams

Members

Static functions

createConsumer

ProtonPublisher!Message createConsumer(ProtonConnection connection, string address)

Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}. Messages will be automatically accepted when the {@link org.reactivestreams.Subscriber#onNext(Object) Subscriber#onNext(Object)} method returns. If you require more control over when the message is accepted, you should use {@link #createDeliveryConsumer(ProtonConnection, String)} instead.

createConsumer

ProtonPublisher!Message createConsumer(ProtonConnection connection, string address, ProtonPublisherOptions options)

Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}. Messages will be automatically accepted when the {@link org.reactivestreams.Subscriber#onNext(Object) Subscriber#onNext(Object)} method returns. If you require more control over when the message is accepted, you should use {@link #createDeliveryConsumer(ProtonConnection, String, ProtonPublisherOptions)} instead.

createDeliveryConsumer

ProtonPublisher!Delivery createDeliveryConsumer(ProtonConnection connection, string address)

Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}. Messages are carried by {@link Delivery} elements of the stream, which are used by the consuming application to explicitly acknowledge each message after processing it.

createDeliveryConsumer

ProtonPublisher!Delivery createDeliveryConsumer(ProtonConnection connection, string address, ProtonPublisherOptions options)

Creates an AMQP consumer, presented as a reactive streams {@link org.reactivestreams.Publisher Publisher}. Messages are carried by {@link Delivery} elements of the stream, which are used by the consuming application to explicitly acknowledge each message after processing it.

createProducer

ProtonSubscriber!Message createProducer(ProtonConnection connection, string address, ProtonSubscriberOptions options)

Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}. The status of the message delivery can not be tracked after send, if you need that ability use {@link ProtonStreams#createTrackerProducer(ProtonConnection, String, ProtonSubscriberOptions)}.

createProducer

ProtonSubscriber!Message createProducer(ProtonConnection connection, string address)

Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}. The status of the message delivery can not be tracked after send, if you need that ability use {@link ProtonStreams#createTrackerProducer(ProtonConnection, String)}.

createTrackerProducer

ProtonSubscriber!Tracker createTrackerProducer(ProtonConnection connection, string address)

Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}.

createTrackerProducer

ProtonSubscriber!Tracker createTrackerProducer(ProtonConnection connection, string address, ProtonSubscriberOptions options)

Creates an AMQP producer, presented as a reactive streams {@link org.reactivestreams.Subscriber Subscriber}.

• ProtonStreams