Class BlockingPullSubscriberImpl (1.8.0)

Version 1.8.0

• 1.15.0 (latest)
• 1.14.8
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class BlockingPullSubscriberImpl implements BlockingPullSubscriber

Inheritance

java.lang.Object > BlockingPullSubscriberImpl

Implements

BlockingPullSubscriber

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

BlockingPullSubscriberImpl(SubscriberFactory factory, FlowControlSettings settings)

public BlockingPullSubscriberImpl(SubscriberFactory factory, FlowControlSettings settings)

Parameters

Name	Description
factory	SubscriberFactory
settings	FlowControlSettings

Methods

close()

public void close()

messageIfAvailable()

public synchronized Optional<SequencedMessage> messageIfAvailable()

Pull messages if there is any ready to deliver. Any message will only be delivered to one call if there are multiple concurrent calls.

Returns

Type	Description
Optional<SequencedMessage>

Exceptions

Type	Description
CheckedApiException

onData()

public synchronized ApiFuture<Void> onData()

Returns a ApiFuture that will be completed when there are messages available. Unfinished existing ApiFuture returned by onData() will be abandoned and superseded by new onData() call.

CheckedApiException will be set to the Future if there is underlying permanent error.

Returns

Type	Description
ApiFuture<Void>