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<String,Object>	getMetricsData()
boolean	isOpen()
void	open(IEventFilter filter)
EventDataWrap	receive()

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(IEventFilter filter)
          throws EventHubException

Specified by:

open in interface IEventHubReceiver

Throws:

EventHubException

close

public void close()

Specified by:

close in interface IEventHubReceiver

isOpen

public boolean isOpen()

Specified by:

isOpen in interface IEventHubReceiver

receive

public EventDataWrap receive()

Specified by:

receive in interface IEventHubReceiver

getMetricsData

public Map<String,Object> getMetricsData()

Specified by:

getMetricsData in interface IEventHubReceiver