Interface AmqpReceiver
- All Superinterfaces:
ReadStream<AmqpMessage>, StreamBase
Interface used to consume AMQP message as a stream of message.
Back pressure is implemented using AMQP credits.
-
Method Summary
Modifier and TypeMethodDescriptionaddress()The listened address.close()Closes the receiver.Gets the connection having created the receiver.endHandler(Handler<Void> endHandler) Set an end handler.exceptionHandler(Handler<Throwable> handler) Set an exception handler on the read stream.fetch(long amount) Fetch the specifiedamountof elements.handler(Handler<AmqpMessage> handler) Set a data handler.pause()Pause theReadStream, it sets the buffer infetchmode and clears the actual demand.resume()Resume reading, and sets the buffer inflowingmode.io.vertx.proton.ProtonReceiverunwrap()Methods inherited from interface ReadStream
blockingStream, collect, pipe, pipeTo
-
Method Details
-
exceptionHandler
Description copied from interface:ReadStreamSet an exception handler on the read stream.- Specified by:
exceptionHandlerin interfaceReadStream<AmqpMessage>- Specified by:
exceptionHandlerin interfaceStreamBase- Parameters:
handler- the exception handler- Returns:
- a reference to this, so the API can be used fluently
-
handler
Description copied from interface:ReadStreamSet a data handler. As data is read, the handler will be called with the data.- Specified by:
handlerin interfaceReadStream<AmqpMessage>- Returns:
- a reference to this, so the API can be used fluently
-
pause
AmqpReceiver pause()Description copied from interface:ReadStreamPause theReadStream, it sets the buffer infetchmode and clears the actual demand.While it's paused, no data will be sent to the data
handler.- Specified by:
pausein interfaceReadStream<AmqpMessage>- Returns:
- a reference to this, so the API can be used fluently
-
resume
AmqpReceiver resume()Description copied from interface:ReadStreamResume reading, and sets the buffer inflowingmode. If theReadStreamhas been paused, reading will recommence on it.- Specified by:
resumein interfaceReadStream<AmqpMessage>- Returns:
- a reference to this, so the API can be used fluently
-
fetch
Description copied from interface:ReadStreamFetch the specifiedamountof elements. If theReadStreamhas been paused, reading will recommence with the specifiedamountof items, otherwise the specifiedamountwill be added to the current stream demand.- Specified by:
fetchin interfaceReadStream<AmqpMessage>- Returns:
- a reference to this, so the API can be used fluently
-
endHandler
Description copied from interface:ReadStreamSet an end handler. Once the stream has ended, and there is no more data to be read, this handler will be called.- Specified by:
endHandlerin interfaceReadStream<AmqpMessage>- Returns:
- a reference to this, so the API can be used fluently
-
address
-
close
-
connection
AmqpConnection connection()Gets the connection having created the receiver. Cannot benull- Returns:
- the connection having created the receiver.
-
unwrap
io.vertx.proton.ProtonReceiver unwrap()- Returns:
- the underlying ProtonReceiver.
-