Package org.ovirt.vdsm.jsonrpc.client.events

Class SubscriptionMatcher

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher

public class SubscriptionMatcher
extends Object

Matcher is responsible for holding all subscriptions and match them to incoming events. Matching process is based on subscription id which is represented by 4 subscription types: <receiver>.<component>.<operation_id>.<unique_id> <receiver> - Uniquely identifies host from which event arrived <component> - Logical component like: Storage, Virt etc <operation_id> - Operation identifier like Image.create <unique_id> - Identifier of a specific operation User can subscribe to all events by defining '*' for each subscription type. Registration for all possible events like '*|*|*|*' is not allowed. User can register for specific component operation using '*|storage|*|*' which means that all events triggered by storage component are delivered to a subscriber.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	SubscriptionMatcher.Predicate

Field Summary

Fields

Modifier and Type	Field	Description
private List<SubscriptionHolder>	allSubscriptions
private ConcurrentMap<String,List<SubscriptionHolder>>	component
private ConcurrentMap<String,List<SubscriptionHolder>>	operation
private ConcurrentMap<String,List<SubscriptionHolder>>	receiver
private ConcurrentMap<String,SubscriptionHolder>	unique_id

Constructor Summary

Constructors

Constructor	Description
SubscriptionMatcher()

Method Summary

Modifier and Type	Method	Description
void	add(SubscriptionHolder holder)	Adds a SubscriptionHolder which will be used for event matching
private void	addHolders(Set<SubscriptionHolder> holders, ConcurrentMap<String,List<SubscriptionHolder>> map, int key, String[] ids, SubscriptionMatcher.Predicate predicate)
private void	clean(ConcurrentMap<String,List<SubscriptionHolder>> map, String key, SubscriptionHolder holder)
List<SubscriptionHolder>	getAllSubscriptions()
Set<SubscriptionHolder>	match(JsonRpcEvent event)	Matches current subscriptions to an event and returns a Set containing all subscriptions that match for this event processing.
void	remove(SubscriptionHolder holder)	Used during removal of a subscription.
private void	update(ConcurrentMap<String,List<SubscriptionHolder>> map, String key, SubscriptionHolder holder)
private void	validateKey(String key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

receiver

private ConcurrentMap<String,List<SubscriptionHolder>> receiver

component

private ConcurrentMap<String,List<SubscriptionHolder>> component

operation

private ConcurrentMap<String,List<SubscriptionHolder>> operation

unique_id

private ConcurrentMap<String,SubscriptionHolder> unique_id

allSubscriptions

private List<SubscriptionHolder> allSubscriptions

Constructor Details

SubscriptionMatcher

public SubscriptionMatcher()

Method Details

add

public void add(SubscriptionHolder holder)

Adds a SubscriptionHolder which will be used for event matching

Parameters:

holder - Instance holding subscription information.

update

private void update(ConcurrentMap<String,List<SubscriptionHolder>> map,
 String key,
 SubscriptionHolder holder)

validateKey

private void validateKey(String key)

match

public Set<SubscriptionHolder> match(JsonRpcEvent event)

Matches current subscriptions to an event and returns a Set containing all subscriptions that match for this event processing.

Parameters:

event - Incoming event used to match subscribers.

Returns:

A Set with matched subscriptions.

addHolders

private void addHolders(Set<SubscriptionHolder> holders,
 ConcurrentMap<String,List<SubscriptionHolder>> map,
 int key,
 String[] ids,
 SubscriptionMatcher.Predicate predicate)

remove

public void remove(SubscriptionHolder holder)

Used during removal of a subscription.

Parameters:

holder - Object holding information about subscription being removed.

clean

private void clean(ConcurrentMap<String,List<SubscriptionHolder>> map,
 String key,
 SubscriptionHolder holder)

getAllSubscriptions

public List<SubscriptionHolder> getAllSubscriptions()