De Depósito
# (assíncrono) addMessageDeliveryFailureListener(mensagemFailedEventListener)
parâmetros:
Nome | Formato | Descrição |
---|---|---|
messageFailedEventListener |
Topic Listener |
# (assíncrono) addTopicDeletedListener(excluirEventListener)
parâmetros:
Nome | Formato | Descrição |
---|---|---|
deleteEventListener |
Topic Listener |
# (assíncrono) criarDurableSubscription(subscriptionName, subscriptionPolicy, messageReceivedListener, intervalo de tempo, deliveryMode) → {Assinatura de Tópico Durável}
parâmetros:
Nome | Formato | Descrição |
---|---|---|
subscriptionName |
corda | |
subscriptionPolicy |
Política de assinatura | |
messageReceivedListener |
Ouvinte de mensagem recebida | |
timespan |
Intervalo de tempo | |
deliveryMode |
Modo de entrega |
retorna:
- Formato
- Assinatura de Tópico Durável
# (assíncrono) criarAssinatura(messageReceivedEventListener, deliveryMode) → {Assinatura do tópico}
parâmetros:
Nome | Formato | Descrição |
---|---|---|
messageReceivedEventListener |
Ouvinte de mensagem recebida | |
deliveryMode |
Modo de entrega |
retorna:
- Formato
- Assinatura do tópico
# getIsClosed() → {booleano}
retorna:
- Formato
- booleano
# getMessageCount() → {número}
retorna:
- Formato
- número
# getNome() → {cadeia}
retorna:
- Formato
- corda
# obter Prioridade() → {Prioridade do tópico}
retorna:
- Formato
- Prioridade do tópico
# getSearchOptions() → {Opções de pesquisa de tópicos}
retorna:
- Formato
- Opções de pesquisa de tópicos
# (assíncrono) publicar(message, deliveryOption, sequenceName, notifyDeliveryFailure)
parâmetros:
Nome | Formato | Padrão | Descrição |
---|---|---|---|
message |
Mensagem | ||
deliverOption |
Opção de entrega | ||
sequenceName |
corda | nulo | |
notifyDeliveryFailure |
booleano | falso |
# (assíncrono) publicar em massa(mensagens, notifiqueDeliveryFailure)
parâmetros:
Nome | Formato | Padrão | Descrição |
---|---|---|---|
messages |
Mapa.Mensagem, Opção de entrega> | ||
notifyDeliveryFailure |
booleano | falso |
# (assíncrono) removeTopicDeletedListener()
Remover o ouvinte
# (assíncrono) setExpirationTime(valor)
parâmetros:
Nome | Formato | Descrição |
---|---|---|
value |
Intervalo de tempo |