A J M O S

A

apply(T) - Method in interface org.apache.ignite.stream.jms11.MessageTransformer

Transformation function.

J

JmsStreamer<T extends javax.jms.Message,K,V> - Class in org.apache.ignite.stream.jms11

Streamer that consumes from a JMS destination and feeds key-value pairs into an IgniteDataStreamer instance.

JmsStreamer() - Constructor for class org.apache.ignite.stream.jms11.JmsStreamer

M

MessageTransformer<T extends javax.jms.Message,K,V> - Interface in org.apache.ignite.stream.jms11

Implement this interface to transform from a Message to a set of cache entries in the form of a Map.

O

org.apache.ignite.stream.jms11 - package org.apache.ignite.stream.jms11

Contains implementation of JMS queue and topic messages consumer.

S

setBatchClosureMillis(long) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

When using batched consumption, sets the time in milliseconds that will elapse before a batch is committed.

setBatchClosureSize(int) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

When using batched consumption, sets the amount of messages that will be received before a batch is committed.

setBatched(boolean) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Batch consumption leverages JMS Transactions to minimise round trips to the broker.

setClientId(String) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the client ID of the JMS Connection.

setConnectionFactory(ConnectionFactory) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the JMS ConnectionFactory.

setDestination(Destination) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the JMS Destination explicitly.

setDestinationName(String) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the name of the JMS destination to consume from.

setDestinationType(Class<? extends Destination>) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the type of the destination to create, when used in combination with setDestinationName(String).

setDurableSubscription(boolean) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

A true value is only accepted in combination with topic consumption.

setDurableSubscriptionName(String) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

When using Durable Subscribers, sets the name of the durable subscriber.

setThreads(int) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Sets the number of threads to concurrently consume JMS messages.

setTransacted(boolean) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Instructs the streamer whether to use local JMS transactions or not.

setTransformer(MessageTransformer<T, K, V>) - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Compulsory.

start() - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Starts streamer.

stop() - Method in class org.apache.ignite.stream.jms11.JmsStreamer

Stops streamer.

A J M O S