Package org.redisson.api
Interface RTopicAsync
-
- All Known Subinterfaces:
RTopic
- All Known Implementing Classes:
RedissonTopic
public interface RTopicAsync
Distributed topic. Messages are delivered to all message listeners across Redis cluster.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <M> >
<M> type, MessageListener<M> listener)
Subscribes to this topic.>
addListenerAsync(StatusListener listener)
Subscribes to status changes of this topic>
countSubscribersAsync()
Returns amount of subscribers to this topic across all Redisson instances.>
message)
Publish the message to all subscribers of this topic asynchronously>
... listenerIds)
Removes the listener byid
for listening this topic>
removeListenerAsync(MessageListener<?> listener)
Removes the listener by its instance
-
-
-
Method Detail
-
publishAsync
> publishAsync( message)
Publish the message to all subscribers of this topic asynchronously- Parameters:
message
- to send- Returns:
- number of clients that received the message
-
addListenerAsync
> addListenerAsync(StatusListener listener)
Subscribes to status changes of this topic- Parameters:
listener
- for messages- Returns:
- listener id
- See Also:
StatusListener
-
addListenerAsync
<M> > addListenerAsync(<M> type, MessageListener<M> listener)
Subscribes to this topic.MessageListener.onMessage
is called when any message is published on this topic.- Type Parameters:
M
- type of message- Parameters:
type
- - type of messagelistener
- for messages- Returns:
- locally unique listener id
- See Also:
MessageListener
-
removeListenerAsync
> removeListenerAsync(... listenerIds)
Removes the listener byid
for listening this topic- Parameters:
listenerIds
- - listener ids- Returns:
- void
-
removeListenerAsync
> removeListenerAsync(MessageListener<?> listener)
Removes the listener by its instance- Parameters:
listener
- - listener instance- Returns:
- void
-
countSubscribersAsync
> countSubscribersAsync()
Returns amount of subscribers to this topic across all Redisson instances. Each subscriber may have multiple listeners.- Returns:
- amount of subscribers
-
-