org.xmlBlaster.client
Class UpdateDispatcher

java.lang.Object
  org.xmlBlaster.client.UpdateDispatcher

public final class UpdateDispatcher
extends java.lang.Object

Dispatches callback messages depending on the subscriptionId to the specific client listener.

Author:

xmlBlaster@marcelruff.info

Constructor Summary

UpdateDispatcher(Global glob)

Method Summary

void	ackSubscription(java.lang.String subscriptionId) Mark that a subscribe() invocation returned (is the server ACK).
void	addCallback(java.lang.String subscriptionId, I_Callback callback, boolean isPersistent) Register a callback interface with the given subscriptionId
void	clear() Remove all callback registrations
int	clearAckNonPersistentSubscriptions() Clear all subscribes which where marked as acknowledged
void	clearNAKSubscriptions() Clear all subscribes which where not marked as acknowledged
I_Callback	getCallback(java.lang.String subscriptionId) Access a callback interface for the given subscriptionId
I_Callback[]	getCallbacks() Returns a current snapshot (shallow copy).
java.lang.String[]	getSubscriptionIds() Returns a current snapshot.
I_Callback	removeCallback(java.lang.String subscriptionId) Remove the callback interface for the given subscriptionId
int	size() Get number of callback registrations

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateDispatcher

public UpdateDispatcher(Global glob)

Method Detail

addCallback

public void addCallback(java.lang.String subscriptionId,
                        I_Callback callback,
                        boolean isPersistent)

Register a callback interface with the given subscriptionId

getCallback

public I_Callback getCallback(java.lang.String subscriptionId)

Access a callback interface for the given subscriptionId

Returns:

null if not found

ackSubscription

public void ackSubscription(java.lang.String subscriptionId)

Mark that a subscribe() invocation returned (is the server ACK).

Parameters:

subscriptionId - The subcribe

getCallbacks

public I_Callback[] getCallbacks()

Returns a current snapshot (shallow copy).

getSubscriptionIds

public java.lang.String[] getSubscriptionIds()

Returns a current snapshot.

removeCallback

public I_Callback removeCallback(java.lang.String subscriptionId)

Remove the callback interface for the given subscriptionId

Returns:

the removed entry of null if subscriptionId is unknown

size

public int size()

Get number of callback registrations

clear

public void clear()

Remove all callback registrations

clearAckNonPersistentSubscriptions

public int clearAckNonPersistentSubscriptions()

Clear all subscribes which where marked as acknowledged

Returns:

number of removed entries

clearNAKSubscriptions

public void clearNAKSubscriptions()

Clear all subscribes which where not marked as acknowledged