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 a connection given a 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.exactlyOnce(boolean enable)
Enables or disables the exactly-once behavior of the sink using
two-phase commit of state snapshots.
|
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.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.