| Package | Description |
|---|---|
| org.jclouds.openstack.marconi.v1.domain | |
| org.jclouds.openstack.marconi.v1.features | |
| org.jclouds.openstack.marconi.v1.options |
| Modifier and Type | Method and Description |
|---|---|
StreamMessagesOptions |
MessageStream.nextStreamOptions()
Only call this method if
nextMarker().isPresent() returns true. |
| Modifier and Type | Method and Description |
|---|---|
MessageStream |
MessageApi.stream(StreamMessagesOptions... options)
Streams the messages off of a queue.
|
| Modifier and Type | Field and Description |
|---|---|
static StreamMessagesOptions |
StreamMessagesOptions.NONE |
| Modifier and Type | Method and Description |
|---|---|
StreamMessagesOptions |
StreamMessagesOptions.echo(boolean echo) |
static StreamMessagesOptions |
StreamMessagesOptions.Builder.echo(boolean echo)
The echo parameter determines whether the API returns a client's own messages, as determined by the clientId
(UUID) portion of the client.
|
StreamMessagesOptions |
StreamMessagesOptions.includeClaimed(boolean includeClaimed) |
static StreamMessagesOptions |
StreamMessagesOptions.Builder.includeClaimed(boolean includeClaimed)
The includeClaimed parameter determines whether the API returns claimed messages.
|
StreamMessagesOptions |
StreamMessagesOptions.limit(int limit) |
static StreamMessagesOptions |
StreamMessagesOptions.Builder.limit(int limit)
When more messages are available than can be returned in a single request, the client can pick up the next
batch of messages by simply using the
StremOptions returned from the previous call in MessageStream#nextStreamOptions(). |
StreamMessagesOptions |
StreamMessagesOptions.marker(String marker) |
static StreamMessagesOptions |
StreamMessagesOptions.Builder.marker(String marker)
Specifies an opaque string that the client can use to request the next batch of messages.
|
StreamMessagesOptions |
StreamMessagesOptions.queryParameters(com.google.common.collect.Multimap<String,String> queryParams)
Many OpenStack interfaces take different params for pagination.
|
static StreamMessagesOptions |
StreamMessagesOptions.Builder.queryParameters(com.google.common.collect.Multimap<String,String> queryParams) |
Copyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.