public class TopicParticipantManager
extends java.lang.Object
Publisher
s and Subscriber
s.Constructor and Description |
---|
TopicParticipantManager() |
public void setListener(TopicParticipantManagerListener listener)
public boolean hasSubscriber(GraphName topicName)
public boolean hasPublisher(GraphName topicName)
public DefaultPublisher<?> getPublisher(GraphName topicName)
public DefaultSubscriber<?> getSubscriber(GraphName topicName)
public void addPublisher(DefaultPublisher<?> publisher)
public void removePublisher(DefaultPublisher<?> publisher)
public void addSubscriber(DefaultSubscriber<?> subscriber)
public void removeSubscriber(DefaultSubscriber<?> subscriber)
public void addSubscriberConnection(DefaultSubscriber<?> subscriber, PublisherIdentifier publisherIdentifier)
public void removeSubscriberConnection(DefaultSubscriber<?> subscriber, PublisherIdentifier publisherIdentifier)
public void addPublisherConnection(DefaultPublisher<?> publisher, SubscriberIdentifier subscriberIdentifier)
public void removePublisherConnection(DefaultPublisher<?> publisher, SubscriberIdentifier subscriberIdentifier)
public java.util.Collection<DefaultSubscriber<?>> getSubscribers()
public java.util.Collection<PublisherIdentifier> getSubscriberConnections(DefaultSubscriber<?> subscriber)
public java.util.Collection<DefaultPublisher<?>> getPublishers()
public java.util.Collection<SubscriberIdentifier> getPublisherConnections(DefaultPublisher<?> publisher)