Paket com.alachisoft.ncache.runtime.caching

Schnittstellenthema

Alle Superinterfaces:

java.lang.AutoCloseable

öffentliche Schnittstelle Betreff
erweitert java.lang.AutoCloseable

Die Themenschnittstelle erleichtert das Erstellen von Abonnements und das Veröffentlichen von Nachrichten für das Thema. Dies ermöglicht auch Ereignisregistrierungen für fehlgeschlagene Nachrichtenübermittlungen, den Empfang von Nachrichten und das Löschen von Themen.

Zusammenfassung der Methode

Modifikator und Typ	Versandart	Beschreibung
void	addMessageDeliveryFailureListener(TopicListener messageFailedEventListener)	Diese Methode registriert Nachrichtenübermittlungsfehlerereignisse zu diesem Thema.
void	addTopicDeletedListener(TopicListener deleteEventListener)	Diese Methode registriert sich für das gelöschte Ereignis des Themas.
DurableTopicSubscription	createDurableSubscription(java.lang.String subscriptionName, SubscriptionPolicy subscriptionPolicy, MessageReceivedListener messageReceivedListener, TimeSpan expirationTime)	Mit dieser Methode wird ein dauerhaftes Abonnement für dieses Thema erstellt.
DurableTopicSubscription	createDurableSubscription(java.lang.String subscriptionName, SubscriptionPolicy subscriptionPolicy, MessageReceivedListener messageReceivedListener, TimeSpan expirationTime, DeliveryMode deliveryMode)	Mit dieser Methode wird ein dauerhaftes Abonnement für dieses Thema erstellt.
TopicSubscription	createSubscription(MessageReceivedListener messageReceivedEventListener)	Diese Methode wird verwendet, um ein Thema im Cache zu abonnieren, wenn ein Thema vorhanden ist. Andernfalls wird eine Ausnahme ausgelöst.
TopicSubscription	createSubscription(MessageReceivedListener messageReceivedEventListener, DeliveryMode deliveryMode)	Diese Methode wird verwendet, um ein Thema im Cache zu abonnieren, wenn ein Thema vorhanden ist. Andernfalls wird eine Ausnahme ausgelöst.
TimeSpan	getExpirationTime()	Ruft die Ablaufzeit der Nachricht für dieses Thema ab.
boolean	getIsClosed()	Gibt an, ob das Thema geschlossen ist oder nicht.
long	getMessageCount()	Ruft die Anzahl der für dieses Thema veröffentlichten Nachrichten ab.
java.lang.String	getName()	Ruft den Namen des Themas ab.
TopicPriority	getPriority()	Die relative Priorität des Themas.
TopicSearchOptions	getSearchOptions()	Gibt an, ob der Benutzer ein musterbasiertes oder ein einfaches Abonnement abonniert hat.
void	publish(Message message, DeliveryOption deliverOption)	Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen.
void	publish(Message message, DeliveryOption deliverOption, boolean notifyDeliveryFailure)	Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen.
void	publish(Message message, DeliveryOption deliverOption, java.lang.String sequenceName)	Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen.
void	publish(Message message, DeliveryOption deliverOption, java.lang.String sequenceName, boolean notifyDeliveryFailure)	Diese Methode wird verwendet, um die Nachricht im Thema mit der angegebenen DeliveryOption und dem angegebenen Sequenznamen zu veröffentlichen.
java.util.concurrent.FutureTask	publishAsync(Message message, DeliveryOption deliverOption)	Diese Methode wird verwendet, um eine Nachricht asynchron im Cache mit der angegebenen DeliveryOption und der Option zu veröffentlichen, den Herausgeber zu benachrichtigen, wenn die Zustellung der Nachricht aufgrund eines Ablaufs, einer Räumung oder eines internen Systemproblems fehlgeschlagen ist.
java.util.concurrent.FutureTask	publishAsync(Message message, DeliveryOption deliverOption, boolean notifyDeliveryFailure)	Diese Methode wird verwendet, um eine Nachricht asynchron im Cache mit der angegebenen DeliveryOption und der Option zu veröffentlichen, den Herausgeber zu benachrichtigen, wenn die Zustellung der Nachricht aufgrund eines Ablaufs, einer Räumung oder eines internen Systemproblems fehlgeschlagen ist.
java.util.Map<Message,java.lang.Exception>	publishBulk(java.util.Map<Message,DeliveryOption> messages)	Diese Methode wird verwendet, um Nachrichten im Thema mit der angegebenen DeliveryOption zu veröffentlichen.
java.util.Map<Message,java.lang.Exception>	publishBulk(java.util.Map<Message,DeliveryOption> messages, boolean notifyDeliveryFailure)	Diese Methode wird verwendet, um Nachrichten im Thema mit der angegebenen DeliveryOption zu veröffentlichen.
void	removeMessageDeliveryFailureListener()	Diese Methode hebt die Registrierung für Nachrichtenübermittlungsfehlerereignisse zu diesem Thema auf.
void	removeTopicDeletedListener()	Diese Methode hebt die Registrierung für das gelöschte Ereignis des Themas auf.
void	setExpirationTime(TimeSpan value)	Legt die Ablaufzeit der Nachricht für dieses Thema fest.

Von der Schnittstelle java.lang.AutoCloseable geerbte Methoden

close

Methodendetails

getName

java.lang.String getName()

Ruft den Namen des Themas ab.

Rücksendung:

Der Name des Themas.

getMessageCount

long getMessageCount() löst eine java.lang.Exception aus

Ruft die Anzahl der für dieses Thema veröffentlichten Nachrichten ab.

Rücksendung:

Die Anzahl der veröffentlichten Nachrichten für dieses Thema.

Wirft:

java.lang.Exception

getPriorität

ThemaPriorität getPriority()

Die relative Priorität des Themas.

Rücksendung:

Die Priorität des Themas.

GetExpirationTime

Zeitspanne getExpirationTime()

Ruft die Ablaufzeit der Nachricht für dieses Thema ab. Sein Standardwert ist TimeSpan.MaxValue.

Rücksendung:

Zeitintervall, nach dem die Nachricht abläuft.

setExpirationTime

void setExpirationTime(Zeitspanne Wert)

Legt die Ablaufzeit der Nachricht für dieses Thema fest.

Parameter:

value - Die Ablaufzeit der Nachricht für dieses Thema.

getIsClosed

boolean getIsClosed()

Gibt an, ob das Thema geschlossen ist oder nicht.

Rücksendung:

True, wenn das Thema geschlossen ist, andernfalls false.

getSearchOptions

ThemenSuchoptionen getSearchOptions()

Gibt an, ob der Benutzer ein musterbasiertes oder ein einfaches Abonnement abonniert hat.

Rücksendung:

Die Themensuchoptionen für dieses Thema.

Abonnement erstellen

ThemaAbonnement Abonnement erstellen(MessageReceivedListener messageReceivedEventListener) löst java.lang.Exception aus

Diese Methode wird verwendet, um ein Thema im Cache zu abonnieren, wenn ein Thema vorhanden ist. Andernfalls wird eine Ausnahme ausgelöst. Diese Methode verwendet den synchronen Zustellungsmodus, der es registrierten Abonnenten ermöglicht, Nachrichten in derselben Reihenfolge zu empfangen, in der sie veröffentlicht werden.

Parameter:

messageReceivedEventListener – Die Nachricht wird über diesen Listener übermittelt.

Rücksendung:

Es gibt das erstellte Themenabonnement zurück.

Wirft:

java.lang.Exception

Abonnement erstellen

ThemaAbonnement Abonnement erstellen(MessageReceivedListener messageReceivedEventListener,
                                     Liefermodus deliveryMode) löst java.lang.Exception aus

Diese Methode wird verwendet, um ein Thema im Cache zu abonnieren, wenn ein Thema vorhanden ist. Andernfalls wird eine Ausnahme ausgelöst.

Parameter:

messageReceivedEventListener – Die Nachricht wird über diesen Listener übermittelt.

deliveryMode - Gibt an, ob Nachrichten an registrierte Abonnenten synchron oder asynchron übermittelt werden sollen.

Rücksendung:

Es gibt das erstellte Themenabonnement zurück.

Wirft:

java.lang.Exception

createDurableSubscription

DurableTopicSubscription createDurableSubscription(java.lang.String AbonnementName,
                                                   Abonnementrichtlinie Abonnementrichtlinie,
                                                   MessageReceivedListener messageReceivedListener,
                                                   Zeitspanne Ablaufzeit,
                                                   Liefermodus deliveryMode) wirft CacheException

Mit dieser Methode wird ein dauerhaftes Abonnement für dieses Thema erstellt.

Parameter:

subscriptionName - Abonnementrichtlinie, ob geteilt oder exklusiv.

subscriptionPolicy - Richtlinie, die ein Abonnement ist, ist Shared oder Exclusive.

messageReceivedListener – Die Nachricht wird über diesen Listener übermittelt.

expirationTime – Eine Zeitspanne, die die Ablaufzeit des Abonnements bestimmt.

deliveryMode - Gibt an, ob Nachrichten an registrierte Abonnenten synchron oder asynchron übermittelt werden sollen.

Rücksendung:

Instanz von DurableTopicSubscription.

Wirft:

CacheException

createDurableSubscription

DurableTopicSubscription createDurableSubscription(java.lang.String AbonnementName,
                                                   Abonnementrichtlinie Abonnementrichtlinie,
                                                   MessageReceivedListener messageReceivedListener,
                                                   Zeitspanne ExpirationTime) wirft CacheException

Mit dieser Methode wird ein dauerhaftes Abonnement für dieses Thema erstellt.

Parameter:

subscriptionName – Name des dauerhaften Abonnements.

subscriptionPolicy - Richtlinie, die ein Abonnement ist, ist Shared oder Exclusive.

messageReceivedListener - Die Nachricht wird dem registrierten Benutzer über diesen Listener zugestellt.

expirationTime - Eine Zeitspanne, die die Ablaufzeit des Abonnements angibt.

Rücksendung:

Instanz von DurableTopicSubscription.

Wirft:

CacheException

veröffentlichen

ungültige Veröffentlichung (Nachricht Botschaft,
             Liefermöglichkeit deliveryOption) löst java.lang.Exception aus

Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen. Und die Option, den Herausgeber zu benachrichtigen, wenn die Nachricht aufgrund eines Ablaufs, einer Entfernung oder eines internen Systemproblems nicht zugestellt werden konnte.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

Wirft:

java.lang.Exception

veröffentlichen

ungültige Veröffentlichung (Nachricht Botschaft,
             Liefermöglichkeit deliverOption, boolean noticeDeliveryFailure) löst java.lang.Exception aus

Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen. Und die Option, den Herausgeber zu benachrichtigen, wenn die Nachricht aufgrund eines Ablaufs, einer Entfernung oder eines internen Systemproblems nicht zugestellt werden konnte.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

notifyDeliveryFailure – Gibt an, ob für diese Nachricht ein MessageDeliveryFailure-Ereignis erforderlich ist.

Wirft:

java.lang.Exception

veröffentlichen

ungültige Veröffentlichung (Nachricht Botschaft,
             Liefermöglichkeit deliveryOption, java.lang.String sequenceName) löst java.lang.Exception aus

Diese Methode wird verwendet, um die Nachricht im Cache mit der angegebenen DeliveryOption zu veröffentlichen. Und die Option, den Herausgeber zu benachrichtigen, wenn die Nachricht aufgrund eines Ablaufs, einer Entfernung oder eines internen Systemproblems nicht zugestellt werden konnte.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

sequenceName - Sequenzname der zu veröffentlichenden Nachricht. Die Nachrichten mit demselben Sequenznamen werden in derselben Reihenfolge zugestellt, in der sie veröffentlicht werden.

Wirft:

java.lang.Exception

veröffentlichen

ungültige Veröffentlichung (Nachricht Botschaft,
             Liefermöglichkeit deliverOption, java.lang.String sequenceName, boolescher Wert notificationDeliveryFailure) löst java.lang.Exception aus

Diese Methode wird verwendet, um die Nachricht im Thema mit der angegebenen DeliveryOption und dem angegebenen Sequenznamen zu veröffentlichen. Die Reihenfolge der Nachrichten mit demselben Sequenznamen bleibt erhalten.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

sequenceName - Sequenzname der zu veröffentlichenden Nachricht. Die Nachrichten mit demselben Sequenznamen werden in derselben Reihenfolge zugestellt, in der sie veröffentlicht werden.

notifyDeliveryFailure – Gibt an, ob das MessageDeliveryFailure-Ereignis für diese Nachricht erforderlich ist.

Wirft:

java.lang.Exception

PublishAsync

java.util.concurrent.FutureTask publishAsync(Nachricht Botschaft,
                                             Liefermöglichkeit deliveryOption) löst java.lang.Exception aus

Diese Methode wird verwendet, um eine Nachricht asynchron im Cache mit der angegebenen DeliveryOption und der Option zu veröffentlichen, den Herausgeber zu benachrichtigen, wenn die Zustellung der Nachricht aufgrund eines Ablaufs, einer Räumung oder eines internen Systemproblems fehlgeschlagen ist.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

Rücksendung:

Zukünftige Aufgabe, die im Hintergrund einen Löschvorgang ausführt. Methoden von FutureTask kann verwendet werden, um den Status der Aufgabe zu bestimmen, z. B. isDone(), isCancelled().

Wirft:

java.lang.Exception

PublishAsync

java.util.concurrent.FutureTask publishAsync(Nachricht Botschaft,
                                             Liefermöglichkeit deliverOption, boolean noticeDeliveryFailure) löst java.lang.Exception aus

Diese Methode wird verwendet, um eine Nachricht asynchron im Cache mit der angegebenen DeliveryOption und der Option zu veröffentlichen, den Herausgeber zu benachrichtigen, wenn die Zustellung der Nachricht aufgrund eines Ablaufs, einer Räumung oder eines internen Systemproblems fehlgeschlagen ist.

Parameter:

message - Nachricht veröffentlicht werden.

deliverOption - Gibt an, wie die Nachricht an registrierte Abonnenten übermittelt wird.

notifyDeliveryFailure – Gibt an, ob für diese Nachricht ein MessageDeliveryFailure-Ereignis erforderlich ist.

Rücksendung:

Zukünftige Aufgabe, die im Hintergrund einen Löschvorgang ausführt. Methoden von FutureTask kann verwendet werden, um den Status der Aufgabe zu bestimmen, z. B. isDone(), isCancelled().

Wirft:

java.lang.Exception

veröffentlichenBulk

java.util.MapNachricht,java.lang.Exception>publishBulk(java.util.MapNachricht,Liefermöglichkeit> Nachrichten) wirft CacheException

Diese Methode wird verwendet, um Nachrichten im Thema mit der angegebenen DeliveryOption zu veröffentlichen.

Parameter:

messages - Sammlung von Nachrichten-Zustellungsoptionspaaren in Form einer Karte.

Rücksendung:

Zuordnung, die die Nachricht zusammen mit der Ausnahme enthält, die beim Veröffentlichen der Nachricht aufgetreten ist.

Wirft:

CacheException

veröffentlichenBulk

java.util.MapNachricht,java.lang.Exception>publishBulk(java.util.MapNachricht,Liefermöglichkeit> Nachrichten, boolescher NotifyDeliveryFailure) löst aus CacheException

Diese Methode wird verwendet, um Nachrichten im Thema mit der angegebenen DeliveryOption zu veröffentlichen.

Parameter:

messages - Sammlung von Nachrichten-Zustellungsoptionspaaren in Form einer Karte.

notifyDeliveryFailure – Gibt an, ob das MessageDeliveryFailure-Ereignis für diese Nachricht erforderlich ist.

Rücksendung:

Zuordnung, die die Nachricht zusammen mit der Ausnahme enthält, die beim Veröffentlichen der Nachricht aufgetreten ist.

Wirft:

CacheException

addTopicDeletedListener

void addTopicDeletedListener(TopicListener deleteEventListener)

Diese Methode registriert sich für das gelöschte Ereignis des Themas.

Parameter:

deleteEventListener - Der Listener, der aufgerufen wird, wenn dieses Thema gelöscht wird.

RemoveTopicDeletedListener

void removeTopicDeletedListener()

Diese Methode hebt die Registrierung für das gelöschte Ereignis des Themas auf.

addMessageDeliveryFailureListener

void addMessageDeliveryFailureListener(TopicListener messageFailedEventListener) löst java.lang.Exception aus

Diese Methode registriert Nachrichtenübermittlungsfehlerereignisse zu diesem Thema.

Parameter:

messageFailedEventListener – Der Listener, der aufgerufen wird, wenn die Nachrichtenübermittlung fehlschlägt.

Wirft:

java.lang.Exception

RemoveMessageDeliveryFailureListener

void removeMessageDeliveryFailureListener() löst eine java.lang.Exception aus

Diese Methode hebt die Registrierung für Nachrichtenübermittlungsfehlerereignisse zu diesem Thema auf.

Wirft:

java.lang.Exception