public class EventHubReceiverImpl extends Object implements IEventHubReceiver
Constructor and Description |
---|
EventHubReceiverImpl(EventHubSpoutConfig config,
String partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Map |
getMetricsData() |
boolean |
isOpen() |
void |
open(com.microsoft.eventhubs.client.IEventHubFilter filter) |
EventData |
receive(long timeoutInMilliseconds) |
public EventHubReceiverImpl(EventHubSpoutConfig config, String partitionId)
public void open(com.microsoft.eventhubs.client.IEventHubFilter filter) throws com.microsoft.eventhubs.client.EventHubException
open
in interface IEventHubReceiver
com.microsoft.eventhubs.client.EventHubException
public void close()
close
in interface IEventHubReceiver
public boolean isOpen()
isOpen
in interface IEventHubReceiver
public EventData receive(long timeoutInMilliseconds)
receive
in interface IEventHubReceiver
public Map getMetricsData()
getMetricsData
in interface IEventHubReceiver
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.