org.apache.ignite.stream.zeromq

Class IgniteZeroMqStreamer<K,V>

java.lang.Object

org.apache.ignite.stream.StreamAdapter<byte[],K,V>

org.apache.ignite.stream.zeromq.IgniteZeroMqStreamer<K,V>

All Implemented Interfaces:

AutoCloseable

public class IgniteZeroMqStreamer<K,V>
extends StreamAdapter<byte[],K,V>
implements AutoCloseable

This streamer uses https://github.com/zeromq/jeromq/. Implements socket types listed ZeroMqTypeSocket.

Field Summary

Fields

Modifier and Type	Field and Description
protected IgniteLogger	log Logger.

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

ignite

Constructor Summary

Constructors

Constructor and Description
IgniteZeroMqStreamer(int ioThreads, ZeroMqTypeSocket socketType, @NotNull String addr, byte[] topic)

Method Summary

Modifier and Type	Method and Description
void	close() Stops ZeroMQ streamer.
void	start() Starts ZeroMQ 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

Field Detail

log

protected IgniteLogger log

Logger.

Constructor Detail

IgniteZeroMqStreamer

public IgniteZeroMqStreamer(int ioThreads,
                            ZeroMqTypeSocket socketType,
                            @NotNull
                            @NotNull String addr,
                            byte[] topic)

Parameters:

ioThreads - Threads on context.

socketType - Socket type.

addr - Address to connect zmq.

topic - Topic name for PUB-SUB socket type, otherwise null.

Method Detail

start

public void start()

Starts ZeroMQ streamer.

close

public void close()
           throws Exception

Stops ZeroMQ streamer.

Specified by:

close in interface AutoCloseable

Throws:

Exception