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 |
---|---|
JmsSourceBuilder |
JmsSourceBuilder.connectionFn(DistributedFunction<? super javax.jms.ConnectionFactory,? extends javax.jms.Connection> connectionFn)
Sets the function which creates the connection from connection factory.
|
JmsSourceBuilder |
JmsSourceBuilder.connectionParams(String username,
String password)
Sets the connection parameters.
|
JmsSourceBuilder |
JmsSourceBuilder.consumerFn(DistributedFunction<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn)
Sets the function which creates the message consumer from session.
|
JmsSourceBuilder |
JmsSourceBuilder.destinationName(String destinationName)
Sets the name of the destination.
|
JmsSourceBuilder |
JmsSourceBuilder.flushFn(DistributedConsumer<? super javax.jms.Session> flushFn)
Sets the function which commits the session after consuming each message.
|
static JmsSourceBuilder |
Sources.jmsQueueBuilder(DistributedSupplier<? extends javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build
a custom JMS
StreamSource for the Pipeline API. |
static JmsSourceBuilder |
Sources.jmsTopicBuilder(DistributedSupplier<? extends javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build
a custom JMS
StreamSource for the Pipeline API. |
JmsSourceBuilder |
JmsSourceBuilder.sessionFn(DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionFn)
Sets the function which creates the session from connection.
|
JmsSourceBuilder |
JmsSourceBuilder.sessionParams(boolean transacted,
int acknowledgeMode)
Sets the session parameters.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.