Uses of Class
org.apache.ignite.stream.StreamAdapter

Packages that use StreamAdapter

Package	Description
org.apache.ignite.stream.camel	Contains implementation of Camel Streamer.
org.apache.ignite.stream.jms11	Contains implementation of JMS queue and topic messages consumer.
org.apache.ignite.stream.kafka	Contains implementation of Kafka Streamer.
org.apache.ignite.stream.mqtt	Contains implementation of MQTT topic messages consumer.
org.apache.ignite.stream.rocketmq	Contains implementation of RocketMQStreamer tests.
org.apache.ignite.stream.socket	Contains socket streamer implementation.
org.apache.ignite.stream.storm	StormStreamer -- integration with Apache Storm.
org.apache.ignite.stream.twitter	Contains implementation of Twitter Streamer.
org.apache.ignite.stream.zeromq	Contains implementation of ZeroMQ Streamer.

Uses of StreamAdapter in org.apache.ignite.stream.camel

Subclasses of StreamAdapter in org.apache.ignite.stream.camel

Modifier and Type	Class and Description
class	CamelStreamer<K,V> This streamer consumes messages from an Apache Camel consumer endpoint and feeds them into an Ignite data streamer.

Uses of StreamAdapter in org.apache.ignite.stream.jms11

Subclasses of StreamAdapter in org.apache.ignite.stream.jms11

Modifier and Type	Class and Description
class	JmsStreamer<T extends javax.jms.Message,K,V> Streamer that consumes from a JMS destination and feeds key-value pairs into an IgniteDataStreamer instance.

Uses of StreamAdapter in org.apache.ignite.stream.kafka

Subclasses of StreamAdapter in org.apache.ignite.stream.kafka

Modifier and Type	Class and Description
class	KafkaStreamer<K,V> Server that subscribes to topic messages from Kafka broker and streams its to key-value pairs into IgniteDataStreamer instance.

Uses of StreamAdapter in org.apache.ignite.stream.mqtt

Subclasses of StreamAdapter in org.apache.ignite.stream.mqtt

Modifier and Type	Class and Description
class	MqttStreamer<K,V> Streamer that consumes from a MQTT topic and feeds key-value pairs into an IgniteDataStreamer instance, using Eclipse Paho as an MQTT client.

Uses of StreamAdapter in org.apache.ignite.stream.rocketmq

Subclasses of StreamAdapter in org.apache.ignite.stream.rocketmq

Modifier and Type	Class and Description
class	RocketMQStreamer<K,V> Streamer that subscribes to a RocketMQ topic amd feeds messages into IgniteDataStreamer instance.

Uses of StreamAdapter in org.apache.ignite.stream.socket

Subclasses of StreamAdapter in org.apache.ignite.stream.socket

Modifier and Type	Class and Description
class	SocketStreamer<T,K,V> Server that receives data from TCP socket, converts it to key-value pairs using StreamTupleExtractor and streams into IgniteDataStreamer instance.

Uses of StreamAdapter in org.apache.ignite.stream.storm

Subclasses of StreamAdapter in org.apache.ignite.stream.storm

Modifier and Type	Class and Description
class	StormStreamer<K,V> Apache Storm streamer implemented as a Storm bolt.

Uses of StreamAdapter in org.apache.ignite.stream.twitter

Subclasses of StreamAdapter in org.apache.ignite.stream.twitter

Modifier and Type	Class and Description
class	TwitterStreamer<K,V> Streamer that consumes from a Twitter Streaming API and feeds transformed key-value pairs, by default , into an IgniteDataStreamer instance.

Uses of StreamAdapter in org.apache.ignite.stream.zeromq

Subclasses of StreamAdapter in org.apache.ignite.stream.zeromq

Modifier and Type	Class and Description
class	IgniteZeroMqStreamer<K,V> This streamer uses https://github.com/zeromq/jeromq/.