Package com.streambase.sb.client

Class DequeueResult

java.lang.Object

com.streambase.sb.client.DequeueResult

All Implemented Interfaces:

Iterable<Tuple>

Direct Known Subclasses:

SimpleDequeueResult

public abstract class DequeueResult
extends Object
implements Iterable<Tuple>

Encapsulates the data returned from a dequeue() operation. Contains references to the originating stream, and a list of tuples.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DequeueResult.Interceptor	A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples.

Field Summary

Fields

Modifier and Type	Field	Description
static int	CLOSED	Status code indicating that the connection was closed
static int	GOOD	Status code indicating a normal dequeue
protected StreamProperties	props	Stream properties
protected Throwable	throwable	Throwable exception
static int	TIMEOUT	Status code indicating a timeout during dequeue

Method Summary

Modifier and Type	Method	Description
int	checkStatus()	Check and return the status of this DequeueResult.
Schema	getSchema()	Returns the schema for the tuples dequeued, may return null
StreamBaseURI	getServerURI()	return the server that produced this DequeueResult.
int	getStatus()	Return the status of this DequeueResult.
String	getStreamName()	Returns the name of the stream on which tuples were dequeued.
StreamProperties	getStreamProperties()	Return the StreamProperties for this DequeueResult.
abstract int	getTupleCount()	Returns the number of tuples dequeued.
abstract Iterator<Tuple>	iterator()	Returns an iterator of all tuples.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

GOOD

public static final int GOOD

Status code indicating a normal dequeue

See Also:

Constant Field Values

TIMEOUT

public static final int TIMEOUT

Status code indicating a timeout during dequeue

See Also:

Constant Field Values

CLOSED

public static final int CLOSED

Status code indicating that the connection was closed

See Also:

Constant Field Values

props

protected final StreamProperties props

Stream properties

throwable

protected final Throwable throwable

Throwable exception

Method Detail

getStreamName

public String getStreamName()

Returns the name of the stream on which tuples were dequeued. May return null.

Returns:

the unqualified name of the stream, may return null

getSchema

public Schema getSchema()

Returns the schema for the tuples dequeued, may return null

Returns:

the schema for the tuples dequeued, may return null

Since:

5.0

getStreamProperties

public StreamProperties getStreamProperties()

Return the StreamProperties for this DequeueResult. May return null

Returns:

StreamProperties, may return null

getServerURI

public StreamBaseURI getServerURI()

return the server that produced this DequeueResult. May return null.

Returns:

the server that produced this DequeueResult. May return null.

Since:

5.1

getTupleCount

public abstract int getTupleCount()

Returns the number of tuples dequeued.

Returns:

number of tuples

iterator

public abstract Iterator<Tuple> iterator()

Returns an iterator of all tuples.

Specified by:

iterator in interface Iterable<Tuple>

getStatus

public int getStatus()

Return the status of this DequeueResult.

• GOOD if the DequeueResult contains tuples.
• TIMEOUT if the DequeueResult contains no tuples and the number of milliseconds specified in the dequeue(timeoutMS) method has expired.
• CLOSED if the connection was closed

Returns:

a status code as described

See Also:

if need exceptions collected by this DequeueResult

checkStatus

public int checkStatus()
                throws StreamBaseException

Check and return the status of this DequeueResult. Similar to getStatus() but will throw any exceptions that this DequeueResult has collected.

Returns:

a status code like getStatus()

Throws:

StreamBaseException - if this DequeueResult has collected any exceptions

Since:

7.0

See Also:

getStatus()

toString

public String toString()

Overrides:

toString in class Object