Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
JmsSinkBuilder<T> |
JmsSinkBuilder.connectionFn(FunctionEx<javax.jms.ConnectionFactory,javax.jms.Connection> connectionFn)
Sets the function which creates the connection from connection factory.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.connectionParams(String username,
String password)
Sets the connection parameters.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.destinationName(String destinationName)
Sets the name of the destination.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.flushFn(ConsumerEx<javax.jms.Session> flushFn)
Sets the function which flushes the session after a batch of messages is
sent.
|
static <T> JmsSinkBuilder<T> |
Sinks.jmsQueueBuilder(SupplierEx<javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build
a custom JMS queue sink for the Pipeline API.
|
static <T> JmsSinkBuilder<T> |
Sinks.jmsTopicBuilder(SupplierEx<javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build
a custom JMS topic sink for the Pipeline API.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.messageFn(BiFunctionEx<javax.jms.Session,T,javax.jms.Message> messageFn)
Sets the function which creates the message from the item.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.sendFn(BiConsumerEx<javax.jms.MessageProducer,javax.jms.Message> sendFn)
Sets the function which sends the message via message producer.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.sessionFn(FunctionEx<javax.jms.Connection,javax.jms.Session> sessionFn)
Sets the function which creates a session from a connection.
|
JmsSinkBuilder<T> |
JmsSinkBuilder.sessionParams(boolean transacted,
int acknowledgeMode)
Sets the session parameters.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.