org.jboss.aerogear.sync.server.netty

Class NettySubscriber

java.lang.Object

org.jboss.aerogear.sync.server.netty.NettySubscriber

All Implemented Interfaces:

Subscriber<io.netty.channel.ChannelHandlerContext>

public class NettySubscriber
extends Object
implements Subscriber<io.netty.channel.ChannelHandlerContext>

Constructor Summary

Constructors

Constructor and Description
NettySubscriber(String clientId, io.netty.channel.ChannelHandlerContext ctx)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.ChannelHandlerContext	channel() The channel that this subscriber uses to communicate.
String	clientId() The client identifier of this subscriber
boolean	equals(Object o)
int	hashCode()
void	patched(PatchMessage<?> patchMessage) Is called when this subscribers underlying document has been patched, allowing it to handle the PatchMessage.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NettySubscriber

public NettySubscriber(String clientId,
                       io.netty.channel.ChannelHandlerContext ctx)

Method Detail

clientId

public String clientId()

Description copied from interface: Subscriber

The client identifier of this subscriber

Specified by:

clientId in interface Subscriber<io.netty.channel.ChannelHandlerContext>

Returns:

String the subscribers/clients identifier

channel

public io.netty.channel.ChannelHandlerContext channel()

Description copied from interface: Subscriber

The channel that this subscriber uses to communicate.

This can be anything that the subscriber supports, for example it could be object representing a connection, or a simple String representing the communication channel.

Specified by:

channel in interface Subscriber<io.netty.channel.ChannelHandlerContext>

Returns:

T the channel used to communicate.

patched

public void patched(PatchMessage<?> patchMessage)

Description copied from interface: Subscriber

Is called when this subscribers underlying document has been patched, allowing it to handle the PatchMessage.

Specified by:

patched in interface Subscriber<io.netty.channel.ChannelHandlerContext>

Parameters:

patchMessage - the result of patching this subscribers underying document.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object