org.brutusin.rpc.websocket

Class Topic<F,M>

java.lang.Object

org.brutusin.rpc.RpcComponent

org.brutusin.rpc.websocket.Topic<F,M>

Type Parameters:

F - Filter class

M - Message class

public abstract class Topic<F,M>
extends RpcComponent

Author:

Ignacio del Valle Alles idelvall@brutusin.org

Constructor Summary

Constructors

Constructor and Description
Topic()

Method Summary

Modifier and Type	Method and Description
void	fire(F filter, M message)
Type	geFilterType()
Type	getMessageType()
Set<WritableSession>	getSubscribers()
abstract Set<WritableSession>	getSubscribers(F filter)
protected void	onSubscribe(WritableSession session)
protected void	onUnsubscribe(WritableSession session)
void	subscribe()
void	unsubscribe()

Methods inherited from class org.brutusin.rpc.RpcComponent

destroy, getId, getType, init, init

Methods inherited from class java.lang.Object

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

Constructor Detail

Topic

public Topic()

Method Detail

getSubscribers

public final Set<WritableSession> getSubscribers()

getSubscribers

public abstract Set<WritableSession> getSubscribers(F filter)

fire

public final void fire(F filter,
                       M message)
                throws Exception

Throws:

Exception

subscribe

public final void subscribe()
                     throws InvalidSubscriptionException

Throws:

InvalidSubscriptionException

unsubscribe

public final void unsubscribe()
                       throws InvalidSubscriptionException

Throws:

InvalidSubscriptionException

onSubscribe

protected void onSubscribe(WritableSession session)

onUnsubscribe

protected void onUnsubscribe(WritableSession session)

geFilterType

public Type geFilterType()

getMessageType

public Type getMessageType()