Package com.microsoft.azure.eventhubs.impl

Class ReceivePump

java.lang.Object

com.microsoft.azure.eventhubs.impl.ReceivePump

All Implemented Interfaces:

Runnable

public class ReceivePump
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReceivePump.IPartitionReceiver

Constructor Summary

Constructors

Constructor	Description
ReceivePump(String eventHubName, String consumerGroupName, ReceivePump.IPartitionReceiver receiver, PartitionReceiveHandler receiveHandler, boolean invokeOnReceiveWithNoEvents, Executor executor)

Method Summary

Modifier and Type	Method	Description
boolean	isRunning()
void	receiveAndProcess()
void	run()
CompletableFuture<Void>	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReceivePump

public ReceivePump(String eventHubName,
                   String consumerGroupName,
                   ReceivePump.IPartitionReceiver receiver,
                   PartitionReceiveHandler receiveHandler,
                   boolean invokeOnReceiveWithNoEvents,
                   Executor executor)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

receiveAndProcess

public void receiveAndProcess()

stop

public CompletableFuture<Void> stop()

isRunning

public boolean isRunning()