org.apache.storm.eventhubs.spout

Class EventHubReceiverImpl

java.lang.Object

org.apache.storm.eventhubs.spout.EventHubReceiverImpl

All Implemented Interfaces:

IEventHubReceiver

public class EventHubReceiverImpl
extends Object
implements IEventHubReceiver

Constructor Summary

Constructors

Constructor and Description
EventHubReceiverImpl(EventHubSpoutConfig config, String partitionId)

Method Summary

Modifier and Type	Method and Description
void	close()
Map	getMetricsData()
boolean	isOpen()
void	open(com.microsoft.eventhubs.client.IEventHubFilter filter)
EventData	receive(long timeoutInMilliseconds)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventHubReceiverImpl

public EventHubReceiverImpl(EventHubSpoutConfig config,
                            String partitionId)

Method Detail

open

public void open(com.microsoft.eventhubs.client.IEventHubFilter filter)
          throws com.microsoft.eventhubs.client.EventHubException

Specified by:

open in interface IEventHubReceiver

Throws:

com.microsoft.eventhubs.client.EventHubException

close

public void close()

Specified by:

close in interface IEventHubReceiver

isOpen

public boolean isOpen()

Specified by:

isOpen in interface IEventHubReceiver

receive

public EventData receive(long timeoutInMilliseconds)

Specified by:

receive in interface IEventHubReceiver

getMetricsData

public Map getMetricsData()

Specified by:

getMetricsData in interface IEventHubReceiver