Method Summary |
|
public Consumer | addConsumerToGroupNamed(String consumerName, String groupName, boolean createGroupIfNeeded, boolean createConsumerIfNeeded) |
public Registration | addRegistrationTo(String consumerName, Map registrationProperties, boolean createConsumerIfNeeded) |
public void | clear() |
public Consumer | createConsumer(String name) |
public ConsumerGroup | createConsumerGroup(String groupName) |
public Consumer | getConsumerByIdentity(String identity) |
public Consumer | getConsumerFor(String registrationHandle) |
public ConsumerGroup | getConsumerGroup(String groupName) |
public Collection | getConsumerGroups() |
public Collection | getConsumers() |
public RegistrationPersistenceManager | getPersistenceManager() |
public RegistrationPolicy | getPolicy() |
public Registration | getRegistration(String registrationHandle) |
public void | policyUpdatedTo(RegistrationPolicy policy) We listen for RegistrationPolicy changes so that we can provide the proper behavior at all time if the policy has
been changed by users since this RegistrationManager was initialized... |
public void | propertiesHaveChanged(Map<QName, ? extends PropertyDescription> registrationProperties) We listen to registration property changes on the producer configuration so that we can invalidate the current
registrations. |
public void | removeConsumer(String identity) |
public void | removeConsumer(Consumer consumer) |
public void | removeConsumerGroup(ConsumerGroup group) |
public void | removeConsumerGroup(String name) |
public void | removeRegistration(String registrationHandle) |
public void | removeRegistration(Registration registration) |
public void | setPersistenceManager(RegistrationPersistenceManager persistenceManager) |
public void | setPolicy(RegistrationPolicy policy) |