Package com.azure.spring.messaging.eventhubs.core

Class EventHubsTemplate

java.lang.Object

com.azure.spring.messaging.eventhubs.core.EventHubsTemplate

All Implemented Interfaces:

SendOperation

public class EventHubsTemplate
extends Object
implements SendOperation

A template for executing sending operations asynchronously to Event Hubs.

Constructor Summary

Constructors

Constructor	Description
EventHubsTemplate(EventHubsProducerFactory producerFactory)	Create an instance using the supplied producer factory.

Method Summary

Modifier and Type	Method	Description
<T> void	send(String destination, Collection<org.springframework.messaging.Message<T>> messages)	Send a Collection<Message> to the given destination synchronously.
<T> void	send(String destination, Collection<org.springframework.messaging.Message<T>> messages, PartitionSupplier partitionSupplier)	Send a Collection<Message> to the given destination with a given partition supplier synchronously.
<T> Mono<Void>	sendAsync(String destination, Collection<org.springframework.messaging.Message<T>> messages)	Send a Collection<Message> to the given destination asynchronously.
<T> Mono<Void>	sendAsync(String destination, Collection<org.springframework.messaging.Message<T>> messages, PartitionSupplier partitionSupplier)	Send a Collection<Message> to the given destination with a given partition supplier asynchronously.
<T> Mono<Void>	sendAsync(String destination, org.springframework.messaging.Message<T> message)
void	setMessageConverter(EventHubsMessageConverter messageConverter)	Set the message converter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.azure.spring.messaging.core.SendOperation

send

Constructor Details

EventHubsTemplate

public EventHubsTemplate(EventHubsProducerFactory producerFactory)

Create an instance using the supplied producer factory.

Parameters:

producerFactory - the producer factory.

Method Details

sendAsync

public <T> Mono<Void> sendAsync(String destination,
 Collection<org.springframework.messaging.Message<T>> messages,
 PartitionSupplier partitionSupplier)

Send a Collection<Message> to the given destination with a given partition supplier asynchronously.

Type Parameters:

T - payload type in message

Parameters:

destination - destination

messages - message set

partitionSupplier - partition supplier

Returns:

Mono Void

sendAsync

public <T> Mono<Void> sendAsync(String destination,
 Collection<org.springframework.messaging.Message<T>> messages)

Send a Collection<Message> to the given destination asynchronously.

Type Parameters:

T - payload type in message

Parameters:

destination - destination

messages - message set

Returns:

Mono Void

send

public <T> void send(String destination,
 Collection<org.springframework.messaging.Message<T>> messages,
 PartitionSupplier partitionSupplier)

Send a Collection<Message> to the given destination with a given partition supplier synchronously.

Type Parameters:

T - payload type in message

Parameters:

destination - destination

messages - message set

partitionSupplier - partition supplier

send

public <T> void send(String destination,
 Collection<org.springframework.messaging.Message<T>> messages)

Send a Collection<Message> to the given destination synchronously.

Type Parameters:

T - payload type in message

Parameters:

destination - destination

messages - message set

sendAsync

public <T> Mono<Void> sendAsync(String destination,
 org.springframework.messaging.Message<T> message)

Specified by:

sendAsync in interface SendOperation

setMessageConverter

public void setMessageConverter(EventHubsMessageConverter messageConverter)

Set the message converter.

Parameters:

messageConverter - the message converter.