org.apache.ignite.stream.rocketmq

Class RocketMQStreamer<K,V>

java.lang.Object

org.apache.ignite.stream.StreamAdapter<List<org.apache.rocketmq.common.message.MessageExt>,K,V>

org.apache.ignite.stream.rocketmq.RocketMQStreamer<K,V>

All Implemented Interfaces:

org.apache.rocketmq.client.consumer.listener.MessageListener, org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently

public class RocketMQStreamer<K,V>
extends StreamAdapter<List<org.apache.rocketmq.common.message.MessageExt>,K,V>
implements org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently

Streamer that subscribes to a RocketMQ topic amd feeds messages into IgniteDataStreamer instance.

Field Summary

Fields inherited from class org.apache.ignite.stream.StreamAdapter

ignite

Constructor Summary

Constructors

Constructor and Description
RocketMQStreamer()

Method Summary

Modifier and Type	Method and Description
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus	consumeMessage(List<org.apache.rocketmq.common.message.MessageExt> msgs, org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context) Implements MessageListenerConcurrently.consumeMessage(List, ConsumeConcurrentlyContext) to receive messages.
void	setConsumerGrp(String consumerGrp) Sets the name of the consumer group.
void	setNameSrvAddr(String nameSrvAddr) Sets the name server address.
void	setTopic(String topic) Sets the topic to subscribe to.
void	start() Starts streamer.
void	stop() Stops streamer.

Methods inherited from class org.apache.ignite.stream.StreamAdapter

addMessage, getIgnite, getMultipleTupleExtractor, getSingleTupleExtractor, getStreamer, getTupleExtractor, setIgnite, setMultipleTupleExtractor, setSingleTupleExtractor, setStreamer, setTupleExtractor

Methods inherited from class java.lang.Object

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

Constructor Detail

RocketMQStreamer

public RocketMQStreamer()

Method Detail

start

public void start()

Starts streamer.

Throws:

IgniteException - If failed.

stop

public void stop()

Stops streamer.

consumeMessage

public org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus consumeMessage(List<org.apache.rocketmq.common.message.MessageExt> msgs,
                                                                                             org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext context)

Implements MessageListenerConcurrently.consumeMessage(List, ConsumeConcurrentlyContext) to receive messages.

Specified by:

consumeMessage in interface org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently

setTopic

public void setTopic(String topic)

Sets the topic to subscribe to.

Parameters:

topic - The topic to subscribe to.

setConsumerGrp

public void setConsumerGrp(String consumerGrp)

Sets the name of the consumer group.

Parameters:

consumerGrp - Consumer group name.

setNameSrvAddr

public void setNameSrvAddr(String nameSrvAddr)

Sets the name server address.

Parameters:

nameSrvAddr - Name server address