Package com.microsoft.azure.servicebus.primitives

Class CoreMessageSender

java.lang.Object

com.microsoft.azure.servicebus.primitives.ClientEntity

com.microsoft.azure.servicebus.primitives.CoreMessageSender

All Implemented Interfaces:

IAmqpLink, IAmqpSender

public class CoreMessageSender
extends ClientEntity
implements IAmqpSender

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	cancelScheduledMessageAsync(Long[] sequenceNumbers, Duration timeout)
static CompletableFuture<CoreMessageSender>	create(MessagingFactory factory, String clientId, String senderPath, String transferDestinationPath)	Deprecated.
static CompletableFuture<CoreMessageSender>	create(MessagingFactory factory, String clientId, String senderPath, String transferDestinationPath, MessagingEntityType entityType)
com.microsoft.azure.servicebus.primitives.ErrorContext	getContext()
String	getSendPath()
protected CompletableFuture<Void>	onClose()
void	onClose(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
void	onError(Exception completionException)
void	onFlow(int creditIssued)
void	onOpenComplete(Exception completionException)
void	onSendComplete(org.apache.qpid.proton.engine.Delivery delivery)
CompletableFuture<Collection<org.apache.qpid.proton.message.Message>>	peekMessagesAsync(long fromSequenceNumber, int messageCount)
CompletableFuture<long[]>	scheduleMessageAsync(org.apache.qpid.proton.message.Message[] messages, TransactionContext transaction, Duration timeout)
CompletableFuture<Void>	sendAsync(Iterable<org.apache.qpid.proton.message.Message> messages, TransactionContext transaction)
CompletableFuture<Void>	sendAsync(org.apache.qpid.proton.message.Message msg, TransactionContext transaction)

Methods inherited from class com.microsoft.azure.servicebus.primitives.ClientEntity

close, closeAsync, finalize, getClientId, getIsClosed, getIsClosingOrClosed, setClosed, setClosing, throwIfClosed

Methods inherited from class java.lang.Object

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

Method Detail

create

@Deprecated
public static CompletableFuture<CoreMessageSender> create(MessagingFactory factory,
                                                          String clientId,
                                                          String senderPath,
                                                          String transferDestinationPath)

Deprecated.

create

public static CompletableFuture<CoreMessageSender> create(MessagingFactory factory,
                                                          String clientId,
                                                          String senderPath,
                                                          String transferDestinationPath,
                                                          MessagingEntityType entityType)

getSendPath

public String getSendPath()

sendAsync

public CompletableFuture<Void> sendAsync(Iterable<org.apache.qpid.proton.message.Message> messages,
                                         TransactionContext transaction)

sendAsync

public CompletableFuture<Void> sendAsync(org.apache.qpid.proton.message.Message msg,
                                         TransactionContext transaction)

onOpenComplete

public void onOpenComplete(Exception completionException)

Specified by:

onOpenComplete in interface IAmqpLink

Parameters:

completionException - completionException=null if open is successful

onClose

public void onClose(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)

Specified by:

onClose in interface IAmqpLink

onError

public void onError(Exception completionException)

Specified by:

onError in interface IAmqpLink

onSendComplete

public void onSendComplete(org.apache.qpid.proton.engine.Delivery delivery)

Specified by:

onSendComplete in interface IAmqpSender

getContext

public com.microsoft.azure.servicebus.primitives.ErrorContext getContext()

onFlow

public void onFlow(int creditIssued)

Specified by:

onFlow in interface IAmqpSender

onClose

protected CompletableFuture<Void> onClose()

Specified by:

onClose in class ClientEntity

scheduleMessageAsync

public CompletableFuture<long[]> scheduleMessageAsync(org.apache.qpid.proton.message.Message[] messages,
                                                      TransactionContext transaction,
                                                      Duration timeout)

cancelScheduledMessageAsync

public CompletableFuture<Void> cancelScheduledMessageAsync(Long[] sequenceNumbers,
                                                           Duration timeout)

peekMessagesAsync

public CompletableFuture<Collection<org.apache.qpid.proton.message.Message>> peekMessagesAsync(long fromSequenceNumber,
                                                                                               int messageCount)